Context scoped onCompletion() not closing RabbitMQ connection

Hi, I have a context scoped onCompletion() that sends to RabbitMQ. When Camel is shutdown it doesn't close the connection to RabbitMQ. If the onCompletion() is route scoped the connection is closed. This test shows the problem. I expect the SendProcessor to be shutdown when the CamelContext is shu

Camel JPA batch insert; exception handling on single bad record.

Using Camel 2.15.1, aggregator to JPA endpoint for batching inserts of 75 records (or every 10s). This approach works fine, downside is when database chokes on single bad record, entire batch is rolled-back. We catch DataException with original list of records with the goal of removing the bad reco

Log message body with EventNotifierSupport

Hello, i am new in camel. I am trying to use EventNotifierSupport to log details about exchange messages. I am trying to use getSource method to get the message body as a String but i get only the Exchange Id. Is there other way to get the String representation of exchange event? Thanks -- Vie

Re: Rest to Stax not working

Hi Doug Douglass, Your suggeston worked. Thanks a lot. Now my working code look like this .post().consumes("text/plain") .type(String.class) .produces("text/plain") .outType(String.class) .to("direct:multicastdemo")