X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fdmaap%2FDmaapMessageConsumer.java;h=3cc1b77d2f9cad3b37b99ae66d9ae26d336d0f95;hb=889b38fd05bc9143647827742e3a8e0f10783bc8;hp=e72fcf0b253fc9c8b65c2f3f4c17a370b0c2ff82;hpb=dede1d28c8f37bb21fae806f00f8315b923670c1;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumer.java b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumer.java index e72fcf0b..3cc1b77d 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumer.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumer.java @@ -40,6 +40,10 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; +/** + * The class fetched incoming requests from DMAAP on regular intervals. Each + * received request is proceesed by DmaapMessageHandler. + */ @Component public class DmaapMessageConsumer implements Runnable {