Transaction rollback with Camel JBI endpoint

[Raphaël Delaporte]

Hi,

I'm using SMX 3.3.1 with the JMS component 2009.01.

I use the jms-consumer endpoint in the XA transacted mode.
This works, because if I want to test the transactionnal behaviour, I
specify some wrong service endpoint and my JMS message is rolledback to the
queue. So that's OK.

But my route calls the Camel JBI endpoint within the transaction.
If I throw any exception from a camel bean, the transaction is not
rolledback, and the JMS message is not redelivered into the queue.
It seems the transaction is commited.

Here is my configuration :

--- JMS SMX component -----
<jms:consumer service="esb:jmsConsumerTrans" endpoint="jmsConsumer"
        targetService="esb:CamelTrans" targetEndpoint="trans"
        destinationName="queue/in" connectionFactory="#connectionFactory"
        transacted="xa" />


--- Camel route -----
public void configure() throws Exception {

        errorHandler(noErrorHandler());

        from("jbi:endpoint:http://esb/CamelTrans/trans";)
        .to(LOG)
        .beanRef("routes", "erreur");

    }

    public void erreur() throws Exception {
        Thread.sleep(1000);
        throw new Exception("erreur ...");
    }



There is something strange to me (and this is why I guess this is a SMX
related and not Camel related). I've enabled the debug mode, and I can see
the content of the messages. In the last exchange, I can see an error field
with my exception (the one which comes from the Camel endpoint I guess)

WARN  - SimpleEndpoint                 - SimpleEndpoint.fail called:
DEBUG - DeliveryChannelImpl            - Send
ID:192.168.0.3-12638f8f9d2-11:0 in DeliveryChannel{servicemix-camel}
DEBUG - SecuredBroker                  - send exchange with secure broker
DEBUG - SedaFlow                       - Called Flow send
DEBUG - SedaQueue                      -
org.apache.servicemix.jbi.nmr.flow.seda.sedaqueu...@517bc3 dequeued
exchange: InOnly[
  id: ID:192.168.0.3-12638f8f9d2-11:0
  status: Error
  role: consumer
  service: {http://esb}CamelTrans
  endpoint: trans
  in: <?xml version="1.0" encoding="UTF-8"?><requete xmlns="http://esb"/>
  error: java.lang.Exception: erreur ...
]
DEBUG - DeliveryChannelImpl            - Notifying exchange
ID:192.168.0.3-12638f8f9d2-11:0(1b9bbe8) in DeliveryChannel{servicemix-jms}
from processInboundSynchronousExchange
DEBUG - DeliveryChannelImpl            - Notified:
ID:192.168.0.3-12638f8f9d2-11:0(1b9bbe8) in DeliveryChannel{servicemix-jms}
from sendSync


Thanks for your help !
Raphaël