Mock endpoint

MockEndpoint.java

private void configureMockEndpoint() throws Exception {
	final AdviceWithRouteBuilder mockAdvice = new AdviceWithRouteBuilder() {

		@Override
		public void configure() throws Exception {
			 replaceFromWith("direct:deadLetterQueueMock");
			 interceptSendToEndpoint("jms:*")
			 	.skipSendToOriginalEndpoint()
			 	.process(exchange -> exchange.getIn().setBody(TEST_BODY_PAYLOAD));
		};
	};
		
	context().getRouteDefinition(ServiceConstants.QUEUE_READER_ROUTE_ID).adviceWith(context(), mockAdvice);
}