activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jpederzolli <jpederzo...@gmail.com>
Subject AMQ 3.2/Spring/Jencks/POJO and XA Transactions
Date Fri, 24 Mar 2006 16:16:35 GMT

I'm reposting this from the LogicBlaze forum...

I havent been able to get transactions to rollback and retry properly using
this combination of technologies. Below is the pertinent spring
configuration:

Code:

 	<bean id="jencks" class="org.jencks.JCAContainer">
 		<property name="bootstrapContext">
 			<bean class="org.jencks.factory.BootstrapContextFactoryBean">
 				<property name="threadPoolSize" value="25" />
 			</bean>
 		</property>
 		<property name="resourceAdapter" ref="resourceAdapter" />
 	</bean>
 
 	<bean id="resourceAdapter"
class="org.activemq.ra.ActiveMQResourceAdapter">
 		<property name="serverUrl" value="tcp://localhost:61616" />
 	</bean>
 
 	<bean id="transactionMdb" class="org.jencks.JCAConnector">
 		<property name="jcaContainer" ref="jencks" />
 		<property name="activationSpec">
 			<bean class="org.activemq.ra.ActiveMQActivationSpec">
 				<property name="destination" value="transactionQueue" />
 				<property name="destinationType" value="javax.jms.Queue" />
 				<property name="resourceAdapter" ref="resourceAdapter" />
 			</bean>
 		</property>
 		<property name="ref" value="consumer" />
 		<property name="transactionManager" ref="userTransaction" />
 		<property name="resourceAdapter" ref="resourceAdapter" />
 	</bean>
 
 	<bean id="consumer" class="com.test.Consumer"/>
 
 
 	<bean id="transactionContextManager"
class="org.jencks.factory.TransactionContextManagerFactoryBean" />
 	<bean id="userTransaction"
class="org.jencks.factory.GeronimoTransactionManagerFactoryBean" />
 	<bean id="jtaTransactionManager"
class="org.springframework.transaction.jta.JtaTransactionManager">
 		<property name="userTransaction" ref="userTransaction" />
 	</bean>
 
 	<bean id="jmsFactory" class="org.activemq.pool.PooledConnectionFactory">
 		<property name="connectionFactory">
 			<bean class="org.activemq.ActiveMQConnectionFactory">
 				<property name="brokerURL" value="tcp://localhost:61616" />
 			</bean>
 		</property>
 	</bean>
 
 	<bean id="transactionJmsTemplate"
class="org.springframework.jms.core.JmsTemplate">
 		<property name="connectionFactory" ref="jmsFactory"/>
 		<property name="defaultDestinationName" value="transactionQueue" />
 		<property name="deliveryPersistent" value="true" />
 	</bean>
 



I am throwing a RuntimeException in the onMessage() method of the POJO MDB
if a rollback should occur. The following is in the logs:

Code:

 [DEBUG] 2006-03-22 12:05:11,810  - org.activemq.ra.ServerSessionImpl:0
(ServerSessionImpl.java:169)- Endpoint failed to process message.
 java.lang.RuntimeException: Endpoint before delivery notification failure
 	at
org.activemq.ra.ServerSessionImpl.beforeDelivery(ServerSessionImpl.java:203)
 	at org.activemq.ActiveMQSession.run(ActiveMQSession.java:549)
 	at org.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:165)
 	at
org.apache.geronimo.connector.work.WorkerContext.run(WorkerContext.java:291)
 	at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(Unknown
Source)
 	at java.lang.Thread.run(Thread.java:595)
 Caused by: org.activemq.ra.InvalidMessageEndpointException
 	at
org.activemq.ra.MessageEndpointProxy$MessageEndpointDead.beforeDelivery(MessageEndpointProxy.java:182)
 	at
org.activemq.ra.MessageEndpointProxy.beforeDelivery(MessageEndpointProxy.java:70)
 	at
org.activemq.ra.ServerSessionImpl.beforeDelivery(ServerSessionImpl.java:201)
 	... 5 more
 



is there an issue with my spring configuration? Thanks for any help
--
View this message in context: http://www.nabble.com/AMQ-3.2-Spring-Jencks-POJO-and-XA-Transactions-t1337311.html#a3574167
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message