BuildProducerRoute.java

    public void buildProducerRoute(CamelContext context) throws Exception {
        context.addRoutes(new RouteBuilder() {
            
            @Override
            public void configure() throws Exception {
               
                Processor processor = (Exchange exchange) -> {
                    System.out.println("PRODUCER Received response: " + exchange.getIn().getBody(String.class));
                };

                from("file:///Users/RobTerpilowski/tmp/in")
                .to("jms-broker:queue:robt.test.queue?exchangePattern=InOut")
                .process(processor);

            }
        });
    }