Atomikos and JmsTemplate

[giovannibotta]

Hello everybody,
I'm a spring newbie and I'm trying to get some relatively simple stuff to work. My task is to read n messages from a JMS queue and persist them to a database all in a single transaction. I'm using Atomikos as the transaction manager and I was trying to have Spring tie everything together. So here's my configuration file:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
	xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/jdbc 
	http://www.springframework.org/schema/jdbc/spring-jdbc-3.1.xsd 
	http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
	http://www.springframework.org/schema/tx
	http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
	http://www.springframework.org/schema/context
	http://www.springframework.org/schema/context/spring-context-3.1.xsd">

	<!-- Configure the JMS connector; call init to register for recovery! -->
	<bean id="ConnectionFactory" class="com.atomikos.jms.AtomikosConnectionFactoryBean"
		init-method="init" destroy-method="close">
		<property name="uniqueResourceName" value="ADCqueue" />
		<property name="xaConnectionFactory">
			<bean class="com.tibco.tibjms.TibjmsXAQueueConnectionFactory">
				<property name="serverUrl" value="tcp://10.254.166.140:7222" />
				<property name="userName" value="analyticsdatacloud" />
				<property name="userPassword" value="an@lytic$datacloud" />
			</bean>
		</property>
		<property name="localTransactionMode" value="false" />
	</bean>

	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory">
			<ref bean="ConnectionFactory" />
		</property>
		<property name="defaultDestination">
			<bean class="com.tibco.tibjms.TibjmsQueue">
				<property name="address" value="TR.OCP01QD.ANALYTICS.DATA.CLOUD.1" />
			</bean>
		</property>
		<property name="receiveTimeout" value="60000" />
		<property name="sessionTransacted" value="true" />
	</bean>

	<!-- Configure the database -->
	<bean id="dataSource" class="com.atomikos.jdbc.nonxa.AtomikosNonXADataSourceBean"
		init-method="init" destroy-method="close">
		<property name="uniqueResourceName" value="DataSource" />
		<property name="driverClassName" value="org.postgresql.Driver" />
		<property name="user" value="postgres" />
		<property name="password" value="postgres" />
		<property name="url" value="jdbc:postgresql://localhost:5432/lrg" />
		<property name="poolSize" value="2" />
	</bean>


	<!-- Configure the Spring framework to use JTA transactions from Atomikos -->
	<bean id="JtaTransactionManager"
		class="org.springframework.transaction.jta.JtaTransactionManager">
		<property name="transactionManager">
			<bean class="com.atomikos.icatch.jta.UserTransactionManager"
				init-method="init" destroy-method="close">
				<!-- when close is called, should we force transactions to terminate 
					or not? -->
				<property name="forceShutdown" value="false" />
			</bean>
		</property>
		<property name="userTransaction">
			<bean class="com.atomikos.icatch.jta.UserTransactionImp">
				<property name="transactionTimeout" value="300" />
			</bean>
		</property>
	</bean>

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

Unfortunately this doesn't work for me. After I obtain my jmsTemplate bean and call the receive method, I get an error:

2013-02-19 15:27:06,650 [main] WARN  com.atomikos.jms.ConsumerProducerSupport - atomikos MessageConsumer proxy for QueueReceiver[queue=TR.OCP01QD.ANALYTICS.DATA.CLOUD.1]: The JMS session you are using requires a JTA transaction context for the calling thread and none was found.
Please correct your code to do one of the following: 
1. start a JTA transaction if you want your JMS operations to be subject to JTA commit/rollback, or
2. increase the maxPoolSize of the AtomikosConnectionFactoryBean to avoid transaction timeout while waiting for a connection, or
3. create a non-transacted session and do session acknowledgment yourself, or
4. set localTransactionMode to true so connection-level commit/rollback are enabled.
2013-02-19 15:27:06,650 [main] WARN  com.atomikos.jms.AtomikosTransactionRequiredJMSException - The JMS session you are using requires a JTA transaction context for the calling thread and none was found.
Please correct your code to do one of the following: 
1. start a JTA transaction if you want your JMS operations to be subject to JTA commit/rollback, or
2. increase the maxPoolSize of the AtomikosConnectionFactoryBean to avoid transaction timeout while waiting for a connection, or
3. create a non-transacted session and do session acknowledgment yourself, or
4. set localTransactionMode to true so connection-level commit/rollback are enabled.
2013-02-19 15:27:06,651 [main] WARN  com.atomikos.jms.AtomikosJMSException - Error in proxy
com.atomikos.jms.AtomikosTransactionRequiredJMSException: The JMS session you are using requires a JTA transaction context for the calling thread and none was found.
Please correct your code to do one of the following: 
1. start a JTA transaction if you want your JMS operations to be subject to JTA commit/rollback, or
2. increase the maxPoolSize of the AtomikosConnectionFactoryBean to avoid transaction timeout while waiting for a connection, or
3. create a non-transacted session and do session acknowledgment yourself, or
4. set localTransactionMode to true so connection-level commit/rollback are enabled.
	at com.atomikos.jms.AtomikosTransactionRequiredJMSException.throwAtomikosTransactionRequiredJMSException(AtomikosTransactionRequiredJMSException.java:40)
	at com.atomikos.jms.ConsumerProducerSupport.enlist(ConsumerProducerSupport.java:112)
	at com.atomikos.jms.AtomikosJmsMessageConsumerProxy.receive(AtomikosJmsMessageConsumerProxy.java:72)
	at com.atomikos.jms.AtomikosJmsMessageConsumerProxy.receive(AtomikosJmsMessageConsumerProxy.java:139)
	at org.springframework.jms.core.JmsTemplate.doReceive(JmsTemplate.java:774)
	at org.springframework.jms.core.JmsTemplate.doReceive(JmsTemplate.java:741)
	at org.springframework.jms.core.JmsTemplate.doReceive(JmsTemplate.java:722)
	at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:697)
	at org.springframework.jms.core.JmsTemplate$9.doInJms(JmsTemplate.java:695)
	at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)
	at org.springframework.jms.core.JmsTemplate.receiveSelected(JmsTemplate.java:695)
	at org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:677)
	at org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:669)

I'm sure this is a rookie mistake, can anyone point that out for me?
Thanks!

Giovanni

[vaijesh]

Try using XA datasource.
Also refer http://www.javaworld.com/javaworld/j...xa.html?page=5 for Atomikos configuration.

Vaijesh

[giovannibotta]

I actually figured out what was wrong: I didn't create my DAO object using Spring. This is necessary because I have @Transactional annotations in it!
Thanks