This repository contains an example of how to configure a Camel route that can read from an Oracle AQ queue and write to an Oracle database table in a single transaction.
This example uses Atomikos as the transaction manager; the key to making this work is proxying both the JMS connection factory and the JDBC data source with Atomikos classes, which takes care of enlisting the resources in a transaction.
This code requires an Oracle schema with a queue and table - see aq_setup.txt for details.
To build the sample, you'll need to add the oracle AQ jar and the oracle jdbc jar to your maven repository, as these do not seem to be available via a public repository.
You will also need to make sure Oracle is configured to support XA transactions, and that your database user has execute privileges on the sys.dbms_system package.
If you are using Oracle XA, there is additional configuration needed to avoid errors.
Finally, you'll need plenty of head room when you run the sample, so a JVM option of -Xmx2014m would be appropriate.
Note the sample can also be used in Fuse ESB. Simple install the following bundles:
install -s mvn:org.springframework/spring-jdbc/3.1.3.RELEASE
install -s wrap:mvn:com.oracle/ojdbc6/11.1.0
install -s wrap:mvn:com.oracle/aqapi/11.1
install -s mvn:com.atomikos/transactions-osgi/3.8.0
install -s mvn:com.atomikos/transactions-jdbc/3.8.0
install -s mvn:com.atomikos/transactions-jms/3.8.0
install -s mvn:camel-oracle/camel-oracle/1.0-SNAPSHOT