Spring integration flow and XA transactions

[Amol Nayak]

Regarding the issue,

14:17:13.101 [xaQueueListener-4] INFO  c.a.jms.AtomikosJmsNonXaSessionProxy - atomikos non-xa session proxy
for vendor instance com.tibco.tibjms.TibjmsxSessionImp@1549ceb: WARNING - detected JTA transaction context 
while using non-transactional session.

Any reason for defining both and using them?

<bean id="jmsConnection" class="com.tibco.tibjms.TibjmsQueueConnectionFactory"
          p:serverUrl="tcp://localhost:7222" p:userName="admin"
          p:userPassword=""/>


    <bean id="xaJmsConnection" class="com.tibco.tibjms.TibjmsXAConnectionFactory"
          p:serverUrl="tcp://localhost:7222" p:userName="admin"
          p:userPassword=""/>

instead just use com.tibco.tibjms.TibjmsXAQueueConnectionFactory

I can't start transaction without poller. Is It correct behaviour or my configuration mistake?

What poller are you referring to? You have a message-driven-channel-adapter which doesn't require a poller sub element. The transaction are demarcated by the transaction-manager attribute or the one confugured with the container in your case.

Below is the line from the documentation regarding message-driven-channel-adapter

The poller sub-element is not applicable for a message-driven Channel Adapter, as it will be actively invoked.

Are things working as you are expecting them to, or you still are facing problems?

[sith]

Ok. Let's talk about simple scenario

context.xml(fragment)

Lets make assumption - myTransformer throw exception. I expect that transactions of flow will be rollbacked. But It didn't happened. database is not rolled back.

What do I need to fix in flow for transactions rollbacking?

    <tx:annotation-driven transaction-manager="txManager"/>


    <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <jdbc:embedded-database id="dataSource" type="H2">
        <jdbc:script location="classpath:db-schema.sql"/>
    </jdbc:embedded-database>


    <int:channel id="in">
    </int:channel>

    <int:channel id="transformChannel"/>

    <int:channel id="out">
        <int:queue capacity="10"/>
    </int:channel>


    <int-jdbc:outbound-gateway
            update="insert into message (id, message) values (1,'Hello')"
            request-channel="in" reply-channel="transformChannel" data-source="dataSource"/>


    <int:transformer input-channel="transformChannel" output-channel="out" ref="myTransformer"/>

    <bean id="myTransformer" class="org.stuff.MyTransformer">
    </bean>

[sith]

Guys. I really need advice.

[Cleric]

Hello

DataSourceTransactionManager isn't XA, so you can't use it with JMS...

And with following with your sample above: Who places the message in the in channel? You should start transaction here.

Cheers,
Artem