X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fdmaap%2FDmaapMessageConsumerTest.java;h=153c4ecc4dbd911170947087be46c401ea752e66;hb=5e8fe3d5256872bda413aabb66cf217e6ef30cef;hp=cd4bcb651bb658e36da788e62357fe1a7a8bc48d;hpb=dede1d28c8f37bb21fae806f00f8315b923670c1;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java b/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java index cd4bcb65..153c4ecc 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java @@ -68,7 +68,7 @@ public class DmaapMessageConsumerTest { @Test public void dmaapNotConfigured_thenDoNothing() { - messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock, false)); + messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock)); doReturn(true).when(messageConsumerUnderTest).sleep(any(Duration.class)); @@ -82,7 +82,7 @@ public class DmaapMessageConsumerTest { @Test public void dmaapConfiguredAndNoMessages_thenPollOnce() throws Exception { - messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock, false)); + messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock)); doReturn(true, false).when(messageConsumerUnderTest).sleep(any(Duration.class)); @@ -113,7 +113,7 @@ public class DmaapMessageConsumerTest { @Test public void dmaapConfiguredAndErrorGettingMessages_thenLogWarning() throws Exception { - messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock, false)); + messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock)); doReturn(true, false).when(messageConsumerUnderTest).sleep(any(Duration.class)); @@ -141,7 +141,7 @@ public class DmaapMessageConsumerTest { @Test public void dmaapConfiguredAndOneMessage_thenPollOnceAndProcessMessage() throws Exception { - messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock, false)); + messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock)); doReturn(true, false).when(messageConsumerUnderTest).sleep(any(Duration.class));