diff options
author | 2019-10-03 13:13:06 -0700 | |
---|---|---|
committer | 2019-11-08 16:38:20 +0000 | |
commit | 7b04a1754482ba02a49d4d6376dc45e4cd6551f4 (patch) | |
tree | 7933ace1bcbc66eadf0443b37c719b5b15b942fe /appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/test/java/org/onap/appc/adapter/messaging/dmaap/impl/EventSenderDmaapImplTest.java | |
parent | 4c2899ac39fede0c276a58469ac53eecc776a028 (diff) |
Cleanup of dmaap adapter
Remvoing the part of the appc-dmaap-adapter that uses
the dmaapClient library. This part of the code was not
being used and the dmaap client library has not been
updated for a long time. Also removed several un-used
dependencies.
Change-Id: I690afaecbfe53d88576c43aa8d114fde54c0fe48
Signed-off-by: Patrick Brady <patrick.brady@att.com>
Issue-ID: APPC-1744
Diffstat (limited to 'appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/test/java/org/onap/appc/adapter/messaging/dmaap/impl/EventSenderDmaapImplTest.java')
-rw-r--r-- | appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/test/java/org/onap/appc/adapter/messaging/dmaap/impl/EventSenderDmaapImplTest.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/test/java/org/onap/appc/adapter/messaging/dmaap/impl/EventSenderDmaapImplTest.java b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/test/java/org/onap/appc/adapter/messaging/dmaap/impl/EventSenderDmaapImplTest.java index 76e56d85c..eaad4b844 100644 --- a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/test/java/org/onap/appc/adapter/messaging/dmaap/impl/EventSenderDmaapImplTest.java +++ b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/test/java/org/onap/appc/adapter/messaging/dmaap/impl/EventSenderDmaapImplTest.java @@ -37,6 +37,7 @@ import org.onap.appc.adapter.message.MessageDestination; import org.onap.appc.adapter.message.Producer; import org.onap.appc.adapter.message.event.EventHeader; import org.onap.appc.adapter.message.event.EventMessage; +import org.onap.appc.adapter.messaging.dmaap.http.HttpDmaapProducerImpl; import org.onap.appc.configuration.Configuration; import org.onap.appc.configuration.ConfigurationFactory; import org.onap.appc.exceptions.APPCException; @@ -76,7 +77,12 @@ public class EventSenderDmaapImplTest { EventHeader eventHeader = Mockito.mock(EventHeader.class); Mockito.when(eventHeader.getEventId()).thenReturn("EVENT_ID"); Mockito.when(eventMessage.getEventHeader()).thenReturn(eventHeader); - assertTrue(sender.sendEvent(MessageDestination.DCAE, eventMessage, "TOPIC NAME")); + Producer mockProducer = Mockito.mock(HttpDmaapProducerImpl.class); + Mockito.when(mockProducer.post(Mockito.anyString(), Mockito.anyString())).thenReturn(true); + Map<String,Producer> map = new HashMap<>(); + map.put(MessageDestination.DCAE.toString(),mockProducer); + sender.setProducerMap(map); + assertTrue(sender.sendEvent(MessageDestination.DCAE, eventMessage)); } @Test |