diff options
Diffstat (limited to 'src/test/java/org/onap/dcae/common/DataChangeEventListnerTest.java')
-rw-r--r-- | src/test/java/org/onap/dcae/common/DataChangeEventListnerTest.java | 18 |
1 files changed, 7 insertions, 11 deletions
diff --git a/src/test/java/org/onap/dcae/common/DataChangeEventListnerTest.java b/src/test/java/org/onap/dcae/common/DataChangeEventListnerTest.java index 95c8012..3d48bf2 100644 --- a/src/test/java/org/onap/dcae/common/DataChangeEventListnerTest.java +++ b/src/test/java/org/onap/dcae/common/DataChangeEventListnerTest.java @@ -17,28 +17,21 @@ * limitations under the License. * ============LICENSE_END========================================================= */ + package org.onap.dcae.common; +import static org.mockito.Mockito.when; -import org.glassfish.jersey.media.sse.EventInput; +import java.util.concurrent.LinkedBlockingQueue; import org.glassfish.jersey.media.sse.InboundEvent; -import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.mockito.Mock; import org.mockito.junit.MockitoJUnitRunner; -import static org.mockito.Mockito.*; - import org.onap.dcae.RestConfCollector; -import org.onap.dcae.common.publishing.DMaaPConfigurationParser; -import org.onap.dcae.common.publishing.EventPublisher; -import org.slf4j.LoggerFactory; -import java.nio.file.Path; -import java.nio.file.Paths; -import java.util.concurrent.LinkedBlockingQueue; @RunWith(MockitoJUnitRunner.class) public class DataChangeEventListnerTest { @@ -59,9 +52,12 @@ public class DataChangeEventListnerTest { DataChangeEventListener listner = new DataChangeEventListener(null); listner.onEvent(event); } + @Test public void testDataChangeEventListenerJsonArray() { - when(event.readData()).thenReturn("[{ \"name\":\"Ford\", \"models\":[ \"Fiesta\",\"Focus\", \"Mustang\" ] },{\"name\":\"BMW\", \"models\":[ \"320\", \"X3\",\"X5\" ] },{\"name\":\"Fiat\",\"models\":[ \"500\", \"Panda\" ]}]"); + when(event.readData()).thenReturn("[{ \"name\":\"Ford\", \"models\":[ \"Fiesta\",\"Focus\", \"Mustang\" ] }," + + "{\"name\":\"BMW\", \"models\":[ \"320\", \"X3\",\"X5\" ] },{\"name\":\"Fiat\",\"models\":" + + "[ \"500\", \"Panda\" ]}]"); RestConfCollector.fProcessingInputQueue = new LinkedBlockingQueue<>(4); DataChangeEventListener listner = new DataChangeEventListener(null); listner.onEvent(event); |