X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=appc-service-communicator%2Fappc-service-communicator-bundle%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fappc%2Fsrvcomm%2Fmessaging%2Fevent%2FEventSender.java;h=24442ac8bd209dd619a9573cefeeddaa195b04f9;hb=b16ce237d780314ea8bbaf17cdb432bc694ee7e7;hp=c15670838678255a297e1e4ed89a2e0e536c1766;hpb=790ddb83355800cc037ea1ea3ca8610bb78018d5;p=appc.git diff --git a/appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSender.java b/appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSender.java index c15670838..24442ac8b 100644 --- a/appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSender.java +++ b/appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSender.java @@ -37,7 +37,7 @@ import java.util.Date; import java.util.Map; -public class EventSender +public class EventSender implements EventSenderInterface { private final EELFLogger LOG = EELFManager.getInstance().getLogger(EventSender.class); public static final String PROPERTY_PREFIX = "dmaap.event"; @@ -50,6 +50,7 @@ public class EventSender messagingConnector = new MessagingConnector(); } + @Override public boolean sendEvent(MessageDestination destination, EventMessage msg) { String jsonStr = msg.toJson(); String id = msg.getEventHeader().getEventId(); @@ -58,6 +59,7 @@ public class EventSender return messagingConnector.publishMessage(propertyPrefix, id, jsonStr); } + @Override public boolean sendEvent(MessageDestination destination, EventMessage msg, String eventTopicName) { String jsonStr = msg.toJson(); String id = msg.getEventHeader().getEventId(); @@ -66,6 +68,7 @@ public class EventSender return messagingConnector.publishMessage(propertyPrefix, id, eventTopicName, jsonStr); } + @Override public boolean sendEvent(MessageDestination destination, Map params, SvcLogicContext ctx) throws APPCException { if (params == null) { @@ -94,4 +97,5 @@ public class EventSender return sendEvent(destination, eventMessage); } + }