diff options
author | 2019-03-19 11:43:27 +0000 | |
---|---|---|
committer | 2019-03-19 11:43:27 +0000 | |
commit | f4d4cd1b885c5075f2c62e5c092d51562ce1c4e0 (patch) | |
tree | 159f5d220332323738388ca1696825c274465580 /policy-endpoints/src/test/java/org/onap | |
parent | 5d8847cef17818f95b1dd6eebbd01be8ea7ed662 (diff) | |
parent | b124ec93d5b5ad22867a84624a0a07ab625d4356 (diff) |
Merge "TopicSinkClient support for unmanaged topics"
Diffstat (limited to 'policy-endpoints/src/test/java/org/onap')
-rw-r--r-- | policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/client/TopicSinkClientTest.java | 46 |
1 files changed, 21 insertions, 25 deletions
diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/client/TopicSinkClientTest.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/client/TopicSinkClientTest.java index 725c0418..07630cd4 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/client/TopicSinkClientTest.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/client/TopicSinkClientTest.java @@ -25,7 +25,6 @@ import static org.assertj.core.api.Assertions.assertThatThrownBy; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertSame; import static org.mockito.Matchers.anyString; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.verify; @@ -36,18 +35,13 @@ import java.util.LinkedList; import java.util.List; import java.util.Properties; import java.util.concurrent.atomic.AtomicReference; - import org.junit.AfterClass; import org.junit.Before; import org.junit.Test; -import org.mockito.internal.util.reflection.Whitebox; -import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure; import org.onap.policy.common.endpoints.event.comm.TopicEndpoint; -import org.onap.policy.common.endpoints.event.comm.TopicListener; import org.onap.policy.common.endpoints.event.comm.TopicSink; public class TopicSinkClientTest { - private static final String SINK_FIELD_NAME = "sink"; private static final String TOPIC = "my-topic"; private TopicSinkClient client; @@ -67,10 +61,17 @@ public class TopicSinkClientTest { sinks = Arrays.asList(sink, null); client = new TopicSinkClient2(TOPIC); + + Properties props = new Properties(); + props.setProperty("noop.sink.topics", TOPIC); + + // clear all topics and then configure one topic + TopicEndpoint.manager.shutdown(); + TopicEndpoint.manager.addTopicSinks(props); } @AfterClass - public static void tearDown() throws Exception { + public static void tearDown() { // clear all topics after the tests TopicEndpoint.manager.shutdown(); } @@ -80,25 +81,13 @@ public class TopicSinkClientTest { */ @Test public void testGetTopicSinks() throws Exception { - // clear all topics and then configure one topic - TopicEndpoint.manager.shutdown(); - - final Properties props = new Properties(); - props.setProperty("noop.sink.topics", TOPIC); - TopicEndpoint.manager.addTopicSinks(props); sink = TopicEndpoint.manager.getNoopTopicSink(TOPIC); assertNotNull(sink); final AtomicReference<String> evref = new AtomicReference<>(null); - sink.register(new TopicListener() { - @Override - public void onTopicEvent(final CommInfrastructure infra, final String topic, final String event) { - evref.set(event); - } - }); - + sink.register((infra, topic, event) -> evref.set(event)); sink.start(); client = new TopicSinkClient(TOPIC); @@ -108,10 +97,7 @@ public class TopicSinkClientTest { } @Test - public void testTopicSinkClient_testGetTopic() { - assertEquals(TOPIC, client.getTopic()); - assertSame(sink, Whitebox.getInternalState(client, SINK_FIELD_NAME)); - + public void testTopicSinkClient() { // unknown topic -> should throw exception sinks = new LinkedList<>(); assertThatThrownBy(() -> new TopicSinkClient2(TOPIC)).isInstanceOf(TopicSinkClientException.class) @@ -119,7 +105,17 @@ public class TopicSinkClientTest { } @Test - public void testSend() throws Exception { + public void testTopicSinkClient_GetTopic() throws TopicSinkClientException { + assertEquals(TOPIC, new TopicSinkClient(TopicEndpoint.manager.getNoopTopicSink(TOPIC)).getTopic()); + assertEquals(TOPIC, new TopicSinkClient(TOPIC).getTopic()); + + assertThatThrownBy(() -> new TopicSinkClient((TopicSink) null)).isInstanceOf(IllegalArgumentException.class); + assertThatThrownBy(() -> new TopicSinkClient("blah")).isInstanceOf(TopicSinkClientException.class) + .hasMessage("no sinks for topic: blah"); + } + + @Test + public void testSend() { client.send(Arrays.asList("abc", "def")); verify(sink).send("['abc','def']".replace('\'', '"')); |