Uploaded image for project: 'Data Collection, Analytics, and Events'
  1. Data Collection, Analytics, and Events
  2. DCAEGEN2-1035

DMaapEventPublisher processing of eventList

XMLWordPrintable

      While attempting to send multiple events to VES Collector via curl in the form of an eventList in JSON. The request is accepted. The event types are "fault".

      The ves-collector log (collector.log) outputs that the events are processed/queued correctly, i.e. there is an entry for each event in the eventList submitted.

      [2018-12-13 14:04:52,040][INFO ][pool-3-thread-5][org.onap.dcae.commonFunction.EventProcessor] - QueueSize:2    EventProcessor  Removing element: {"VESversion":"v7","VESuniqueId":"370f23db-0bf5-431a-a158-8c4b54752c4a-0","event":{"commonEventHeader":{"startEpochM
       icrosec":1544016106000000,"eventId":"fault33","timeZoneOffset":"UTC+00.00","priority":"Normal","version":"4.0.1","nfVendorName":"Ericsson","reportingEntityName":"1","sequence":1,"domain":"fault","lastEpochMicrosec":1544016106000000,"eventName":"Fault_KeyFileFault","vesEventListenerVersion":"7.0.1","sourceName":"1"},"faultFields":{"eventSeverity":"CRITICAL","alarmCondition":"KeyFileFault","faultFieldsVersion":"4.0","eventCategory":"PROCESSINGERRORALARM","specificProblem":"License Key File Fault","al
       armAdditionalInformation":{"probableCause":"ConfigurationOrCustomizationError","additionalText":"test","source":"ManagedElement=1,SystemFunctions=1,Lm=1"},"eventSourceType":"Lm","vfStatus":"Active"}}}
       
       [2018-12-13 14:04:52,041][INFO ][pool-3-thread-7][org.onap.dcae.commonFunction.EventProcessor] - QueueSize:0    EventProcessor  Removing element: {"VESversion":"v7","VESuniqueId":"370f23db-0bf5-431a-a158-8c4b54752c4a-2","event":{"commonEventHeader":{"startEpochM
       icrosec":1544016106000000,"eventId":"fault35","timeZoneOffset":"UTC+00.00","priority":"Normal","version":"4.0.1","nfVendorName":"Ericsson","reportingEntityName":"1","sequence":1,"domain":"fault","lastEpochMicrosec":1544016106000000,"eventName":"Fault_KeyFileFault","vesEventListenerVersion":"7.0.1","sourceName":"1"},"faultFields":{"eventSeverity":"CRITICAL","alarmCondition":"KeyFileFault","faultFieldsVersion":"4.0","eventCategory":"PROCESSINGERRORALARM","specificProblem":"License Key File Fault","al
       armAdditionalInformation":{"probableCause":"ConfigurationOrCustomizationError","additionalText":"test","source":"ManagedElement=1,SystemFunctions=1,Lm=3"},"eventSourceType":"Lm","vfStatus":"Active"}}}
       
       [2018-12-13 14:04:52,040][INFO ][pool-3-thread-6][org.onap.dcae.commonFunction.EventProcessor] - QueueSize:1    EventProcessor  Removing element: {"VESversion":"v7","VESuniqueId":"370f23db-0bf5-431a-a158-8c4b54752c4a-1","event":{"commonEventHeader":{"startEpochM
       icrosec":1544016106000000,"eventId":"fault34","timeZoneOffset":"UTC+00.00","priority":"Normal","version":"4.0.1","nfVendorName":"Ericsson","reportingEntityName":"1","sequence":1,"domain":"fault","lastEpochMicrosec":1544016106000000,"eventName":"Fault_KeyFileFault","vesEventListenerVersion":"7.0.1","sourceName":"1"},"faultFields":{"eventSeverity":"CRITICAL","alarmCondition":"KeyFileFault","faultFieldsVersion":"4.0","eventCategory":"PROCESSINGERRORALARM","specificProblem":"License Key File Fault","al
       armAdditionalInformation":{"probableCause":"ConfigurationOrCustomizationError","additionalText":"test","source":"ManagedElement=1,SystemFunctions=1,Lm=2"},"eventSourceType":"Lm","vfStatus":"Active"}}}
       

      However, when I query MR I get the same event listed multiple times rather than each event listed once.

      The log files are showing the following:

       [2018-12-13 14:04:52,103][INFO ][pool-3-thread-6][org.onap.dcae.commonFunction.event.publishing.DMaaPEventPublisher] - Event: '{"event":{"commonEventHeader":{"startEpochMicrosec":1544016106000000,"eventId":"fault35","timeZoneOffset":"UTC+00.00","internalHeaderFi
       elds":{"collectorTimeStamp":"Thu, 12 13 2018 02:04:52 UTC"},"priority":"Normal","version":"4.0.1","nfVendorName":"Ericsson","reportingEntityName":"1","sequence":1,"domain":"fault","lastEpochMicrosec":1544016106000000,"eventName":"Fault_KeyFi
       leFault","vesEventListenerVersion":"7.0.1","sourceName":"1"},"faultFields":{"eventSeverity":"CRITICAL","alarmCondition":"KeyFileFault","faultFieldsVersion":"4.0","eventCategory":"PROCESSINGERRORALARM","specificProblem":"License Key File Fault","alarmAdditionalInformation":{"probableCause":"ConfigurationOrCustomizationError","additionalText":"test","source":"ManagedElement=1,SystemFunctions=1,Lm=3"},"eventSourceType":"Lm","vfStatus":"Active"}}}' scheduled to be send asynchronously on domain: 'ves-fault'
       
       [2018-12-13 14:04:52,112][INFO ][pool-3-thread-5][org.onap.dcae.commonFunction.event.publishing.DMaaPEventPublisher] - Event: '{"event":{"commonEventHeader":{"startEpochMicrosec":1544016106000000,"eventId":"fault35","timeZoneOffset":"UTC+00.00","internalHeaderFields":{"collectorTimeStamp":"Thu, 12 13 2018 02:04:52 UTC"},"priority":"Normal","version":"4.0.1","nfVendorName":"Ericsson","reportingEntityName":"1","sequence":1,"domain":"fault","lastEpochMicrosec":1544016106000000,"eventName":"Fault_KeyFi
       leFault","vesEventListenerVersion":"7.0.1","sourceName":"1"},"faultFields":{"eventSeverity":"CRITICAL","alarmCondition":"KeyFileFault","faultFieldsVersion":"4.0","eventCategory":"PROCESSINGERRORALARM","specificProblem":"License Key File Fault","alarmAdditionalInformation":{"probableCause":"ConfigurationOrCustomizationError","additionalText":"test","source":"ManagedElement=1,SystemFunctions=1,Lm=3"},"eventSourceType":"Lm","vfStatus":"Active"}}}' scheduled to be send asynchronously on domain: 'ves-fault'
       
       [2018-12-13 14:04:52,114][INFO ][pool-3-thread-7][org.onap.dcae.commonFunction.event.publishing.DMaaPEventPublisher] - Event: '{"event":{"commonEventHeader":{"startEpochMicrosec":1544016106000000,"eventId":"fault35","timeZoneOffset":"UTC+00.00","internalHeaderFields":{"collectorTimeStamp":"Thu, 12 13 2018 02:04:52 UTC"},"priority":"Normal","version":"4.0.1","nfVendorName":"Ericsson","reportingEntityName":"1","sequence":1,"domain":"fault","lastEpochMicrosec":1544016106000000,"eventName":"Fault_KeyFi
       leFault","vesEventListenerVersion":"7.0.1","sourceName":"1"},"faultFields":{"eventSeverity":"CRITICAL","alarmCondition":"KeyFileFault","faultFieldsVersion":"4.0","eventCategory":"PROCESSINGERRORALARM","specificProblem":"License Key File Fault","alarmAdditionalIn
       formation":{"probableCause":"ConfigurationOrCustomizationError","additionalText":"test","source":"ManagedElement=1,SystemFunctions=1,Lm=3"},"eventSourceType":"Lm","vfStatus":"Active"}}}' scheduled to be send asynchronously on domain: 'ves-fault'

            zlatkomurgoski zlatkomurgoski
            eronkeo eronkeo
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: