+ MRConsumerResponse response = new MRConsumerResponse();
+ int responseCode = HttpStatus.BAD_REQUEST.value();
+ response.setResponseCode(Integer.toString(responseCode));
+ String responseMessage = "Error";
+ response.setResponseMessage(responseMessage);
+ when(messageRouterConsumerMock.fetchWithReturnConsumerResponse()).thenReturn(response);
+
+ final ListAppender<ILoggingEvent> logAppender =
+ LoggingUtils.getLogListAppender(DmaapMessageConsumer.class, WARN);
+
+ messageConsumerUnderTest.start().join();