BuildConsumerRoute.java

    public void buildConsumerRoute(CamelContext context) throws Exception {
        
        context.addRoutes(new RouteBuilder() {
            
            @Override
            public void configure() throws Exception {
                Processor processor = (Exchange exchange) -> {
                   
                    System.out.println("CONSUMER received message: " + exchange.getIn().getBody(String.class));

                    exchange.getIn().setBody("I Saw it!!! It contained: " + exchange.getIn().getBody(String.class));
                };

                from("jms-broker:queue:robt.test.queue")
                .to("file:///Users/RobTerpilowski/tmp/out")
               .process(processor);

            }
        });
    }