Fix an unexpected error in tests

- Fix an error reported by DMaapEventPublisher test when pk is not available.
Issue-ID: DCAEGEN2-2374

Change-Id: I69c0f89b292c8454f3eebaffe4884928d241f235
Signed-off-by: Zebek Bogumil <bogumil.zebek@nokia.com>

1 files changed, 5 insertions, 5 deletions

diff --git a/src/main/java/org/onap/dcae/common/EventSender.java b/src/main/java/org/onap/dcae/common/EventSender.java
index 1ec918c9..81c463dc 100644
--- a/src/main/java/org/onap/dcae/common/EventSender.java
+++ b/src/main/java/org/onap/dcae/common/EventSender.java
@@ -49,17 +49,17 @@ public class EventSender {
       setLoggingContext(vesEvent);
       streamIdToDmaapIds.get(vesEvent.getStreamId())
           .onEmpty(() -> log.error("No StreamID defined for publish - Message dropped" + vesEvent.asJsonObject()))
-          .forEach(streamIds -> sendEventsToStreams(vesEvent, streamIds));
+          .forEach(dmaapIds -> sendEventsToStreams(vesEvent, dmaapIds));
       log.debug("Message published" + vesEvent.asJsonObject());
     }
     log.debug("CommonStartup.handleEvents:EVENTS has been published successfully!");
     metriclog.info("EVENT_PUBLISH_END");
   }
 
-  private void sendEventsToStreams(VesEvent vesEvent, String[] streamIdList) {
-    for (String streamId : streamIdList) {
-      log.info("Invoking publisher for streamId/domain:" + streamId);
-      eventPublisher.sendEvent(vesEvent.asJsonObject(), streamId);
+  private void sendEventsToStreams(VesEvent vesEvent, String[] dmaapIds) {
+    for (String dmaapId : dmaapIds) {
+      log.info("Invoking publisher for streamId/domain:" + dmaapId);
+      eventPublisher.sendEvent(vesEvent, dmaapId);
     }
   }