@Test
public void dmaapNotConfigured_thenDoNothing() {
- messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock, false));
+ messageConsumerUnderTest = spy(new DmaapMessageConsumer(applicationConfigMock));
doReturn(true).when(messageConsumerUnderTest).sleep(any(Duration.class));
@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));
@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));
@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));