Need a sample of using XA transaction inside camel script with Servicemix

[Pavel Khozhainov <pa...@consumerhealthtech.com>]

Hi all

I need to
1. receive jms
2. update db
3. send jms
inside one XA transaction possible in one route.

Transaction manager is taken form  Servicemix jndi:
It was Jenks tm and it works with XA transactions

    <bean id="txTransactionManager" 
class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiName" 
value="java:comp/env/smx/TransactionManager" />
    </bean>

JMS connection factory is good too

    <bean id="connectionFactory" 
class="org.jencks.amqpool.XaPooledConnectionFactory">
        <constructor-arg value="${jms.broker.url}"/>

        <property name="maxConnections" value="8" />
        <property name="transactionManager" ref="txTransactionManager" />
    </bean>

Next step I specify my db2 datasource

    <bean id="dataSource"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.ibm.db2.jcc.DB2Driver" 
/>
        <property name="url" 
value="jdbc:db2://${db.host}:${db.port}/${db.name}" />
        <property name="username" value="${db.username}" />
        <property name="password" value="${db.password}" />
        <property name="connectionProperties">
            <props>
                <prop key="currentSchema">${db.schema}</prop>
            </props>
        </property>
    </bean>

I can not create real DB2XADataSource because it was DB2JccDataSource not 
java.sql.DataSource
(is the problem here?)

Next step is sessionFactory

    <bean id="sessionFactory" 
class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">

        <property name="jtaTransactionManager" ref="txTransactionManager"/>
        <property name="dataSource" ref="dataSource" />
        <property name="annotatedClasses">
            <list>
... mappings
            </list>
        </property>
        <property name="hibernateProperties">
            <props>
    ... props
            </props>
        </property>
    </bean>

looks normal

Last step is to specify policy - taken from sample

    <bean id="required" 
class="org.apache.camel.spring.spi.SpringTransactionPolicy">
        <property name="template" ref="PROPAGATION_REQUIRED"/>
    </bean>

    <bean id="PROPAGATION_REQUIRED"
        class="org.springframework.transaction.support.TransactionTemplate">
        <property name="transactionManager" ref="txTransactionManager"/>
    </bean>

I write my camel route i following way

        <route errorHandlerRef="deadLetterErrorHandler">

            <from uri="jms:queue:test.tran.01"/>

            <policy ref="required"/>

            <to uri = "bean:rendererBean?methodName=process"/>

            <setBody><el><![CDATA[<message>test</message>]]></el></setBody>

            <to uri = "jms:queue:test.tran.02"/>

        </route>

Problem
When process() method of my bean is called xa transaction was not open.
I expect that <policy step will open it but this was not happen.

Please tell me what to do
- must I specify "xa" somehere as I do with jms eip component?

It is a good idea to add camel xa sample to set of samples
__________
Pavel