public class JmsErrorHandlerRoute extends RouteBuilder { @Override public void configure() throws Exception { onException(Exception.class) .handled(true) from("activemq:queue:inputQueue") .to("bean:processMessage") .to("activemq:queue:outputQueue"); } } public class MessageProcessor { public void processMessage(@Body String message) throws Exception { if (message.contains("error")) { } else { } } }