From b16ce237d780314ea8bbaf17cdb432bc694ee7e7 Mon Sep 17 00:00:00 2001 From: Patrick Brady Date: Tue, 29 Oct 2019 15:35:20 -0700 Subject: Fix dg-common bundle error Fix a dg-common blueprint error that was caused by the changes with the new appc-service-communicator. Added an interface for the EventSender, and created a blueprint file to publish the interface as a service. Change-Id: I37248fcbfa7cfa75e62965dad811b648c336b5e2 Signed-off-by: Patrick Brady Issue-ID: APPC-1744 --- .../appc/srvcomm/messaging/event/EventSender.java | 6 +++- .../messaging/event/EventSenderInterface.java | 14 ++++++++++ .../resources/OSGI-INF/blueprint/blueprint.xml | 32 ++++++++++++++++++++++ 3 files changed, 51 insertions(+), 1 deletion(-) create mode 100644 appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSenderInterface.java create mode 100644 appc-service-communicator/appc-service-communicator-bundle/src/main/resources/OSGI-INF/blueprint/blueprint.xml (limited to 'appc-service-communicator/appc-service-communicator-bundle/src/main') 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); } + } diff --git a/appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSenderInterface.java b/appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSenderInterface.java new file mode 100644 index 000000000..b5bb71de9 --- /dev/null +++ b/appc-service-communicator/appc-service-communicator-bundle/src/main/java/org/onap/appc/srvcomm/messaging/event/EventSenderInterface.java @@ -0,0 +1,14 @@ +package org.onap.appc.srvcomm.messaging.event; + +import java.util.Map; + +import org.onap.appc.exceptions.APPCException; +import org.onap.appc.srvcomm.messaging.MessageDestination; +import org.onap.ccsdk.sli.core.sli.SvcLogicContext; +import org.onap.ccsdk.sli.core.sli.SvcLogicJavaPlugin; + +public interface EventSenderInterface extends SvcLogicJavaPlugin { + boolean sendEvent(MessageDestination destination, EventMessage msg); + boolean sendEvent(MessageDestination destination, EventMessage msg,String eventTopicName); + boolean sendEvent(MessageDestination destination, Map params, SvcLogicContext ctx) throws APPCException; +} diff --git a/appc-service-communicator/appc-service-communicator-bundle/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/appc-service-communicator/appc-service-communicator-bundle/src/main/resources/OSGI-INF/blueprint/blueprint.xml new file mode 100644 index 000000000..603a5bfcc --- /dev/null +++ b/appc-service-communicator/appc-service-communicator-bundle/src/main/resources/OSGI-INF/blueprint/blueprint.xml @@ -0,0 +1,32 @@ + + + + + + + + + + + -- cgit 1.2.3-korg