0002627: ActiveMQ transation

Viewing Issue Advanced Details [ Jump to Notes ]

[ View Simple ] [ Issue History ] [ Print ]

Category

Severity

Reproducibility

Date Submitted

Last Update

0002627

[Resin]

minor

always

04-25-08 14:10

06-12-08 17:10

Reporter

ferg

View Status

public

Assigned To

ferg

Priority

normal

Resolution

fixed

Platform

Status

closed

Projection

none

OS Version

ETA

none

Fixed in Version

3.2.0

Product Version

3.1.6

Product Build

Summary

0002627: ActiveMQ transation

Description

(rep by wesley)

As I'm using ActiveMQ jca adapter on snapshot080331, eventually when producing messages it will throw exceptions.
My message sender:
==================================================
@Named("clearCache")
Topic clearCacheTopic;
@In
ConnectionFactory jmsFactory;
public void sendClearCacheMessage() {
  Connection conn = null;
  try {
   conn = jmsFactory.createConnection();
   Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
   MessageProducer producer = session.createProducer(clearCacheTopic);
   producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
   producer.send(session.createTextMessage("Clear cache at " + DateUtils.toDateTimeString(new Date())));
  } catch (JMSException e) {
   log.warn(StringUtils.stackTraceAsString(e));
  } finally {
   try {
    conn.close();
   } catch (Throwable ignore) {
   }
  }
}
=====================================================================
resin-web.xml
=====================================================================
<resource-adapter uri="activemq:">
  <init server-url="tcp://192.168.1.100:61616"/> [^]
</resource-adapter>
<connection-factory uri="activemq:" name="activemq"/>
<jms-topic uri="activemq:" name="clearCache">
  <init physicalName="topic.clearCache"/>
</jms-topic>
<ejb-message-bean class="com.buysou.cache.ClearCacheListener">
  <destination>#{clearCache}</destination>
</ejb-message-bean>
=====================================================================
ActiveMQ config is at default.

Is there any trick to prevent this exceptions?

-Wesley

stacktrace:

[15:36:37.941] {ActiveMQ Session Task} javax.resource.ResourceException: begin failed.
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.LocalAndXATransaction.begin(LocalAndXATransaction.java:52)
[15:36:37.941] {ActiveMQ Session Task} at com.caucho.jca.PoolItem.localTransactionStarted(PoolItem.java:546)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection.fireBeginEvent(ActiveMQManagedConnection.java:151)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection.access$100(ActiveMQManagedConnection.java:55)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection$2.beginEvent(ActiveMQManagedConnection.java:94)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.TransactionContext.begin(TransactionContext.java:204)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.LocalAndXATransaction.begin(LocalAndXATransaction.java:49)
[15:36:37.941] {ActiveMQ Session Task} at com.caucho.jca.PoolItem.localTransactionStarted(PoolItem.java:546)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection.fireBeginEvent(ActiveMQManagedConnection.java:151)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection.access$100(ActiveMQManagedConnection.java:55)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection$2.beginEvent(ActiveMQManagedConnection.java:94)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.TransactionContext.begin(TransactionContext.java:204)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedTransactionContext.begin(ManagedTransactionContext.java:56)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQSession.doStartTransaction(ActiveMQSession.java:1658)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQMessageConsumer.ackLater(ActiveMQMessageConsumer.java:782)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQMessageConsumer.beforeMessageIsConsumed(ActiveMQMessageConsumer.java:728)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:963)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:122)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:192)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
[15:36:37.941] {ActiveMQ Session Task} at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
[15:36:37.941] {ActiveMQ Session Task} at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
[15:36:37.941] {ActiveMQ Session Task} at java.lang.Thread.run(Thread.java:619)
[15:36:37.941] {ActiveMQ Session Task} Caused by: javax.jms.JMSException: The resource is allready being used in transaction context.
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedTransactionContext.setUseSharedTxContext(ManagedTransactionContext.java:47)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedSessionProxy.setUseSharedTxContext(ManagedSessionProxy.java:65)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedConnectionProxy.setUseSharedTxContext(ManagedConnectionProxy.java:125)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection$1.setInManagedTx(ActiveMQManagedConnection.java:87)
[15:36:37.941] {ActiveMQ Session Task} at org.apache.activemq.ra.LocalAndXATransaction.begin(LocalAndXATransaction.java:50)
[15:36:37.941] {ActiveMQ Session Task} ... 23 more
[15:36:37.945] {ActiveMQ Session Task} javax.resource.ResourceException: begin failed.
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.LocalAndXATransaction.begin(LocalAndXATransaction.java:52)
[15:36:37.945] {ActiveMQ Session Task} at com.caucho.jca.PoolItem.localTransactionStarted(PoolItem.java:546)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection.fireBeginEvent(ActiveMQManagedConnection.java:151)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection.access$100(ActiveMQManagedConnection.java:55)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection$2.beginEvent(ActiveMQManagedConnection.java:94)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.TransactionContext.begin(TransactionContext.java:204)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedTransactionContext.begin(ManagedTransactionContext.java:56)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQSession.doStartTransaction(ActiveMQSession.java:1658)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQMessageConsumer.ackLater(ActiveMQMessageConsumer.java:782)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQMessageConsumer.beforeMessageIsConsumed(ActiveMQMessageConsumer.java:728)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:963)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:122)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:192)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
[15:36:37.945] {ActiveMQ Session Task} at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
[15:36:37.945] {ActiveMQ Session Task} at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
[15:36:37.945] {ActiveMQ Session Task} at java.lang.Thread.run(Thread.java:619)
[15:36:37.945] {ActiveMQ Session Task} Caused by: javax.jms.JMSException: The resource is allready being used in transaction context.
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedTransactionContext.setUseSharedTxContext(ManagedTransactionContext.java:47)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedSessionProxy.setUseSharedTxContext(ManagedSessionProxy.java:65)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ManagedConnectionProxy.setUseSharedTxContext(ManagedConnectionProxy.java:125)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.ActiveMQManagedConnection$1.setInManagedTx(ActiveMQManagedConnection.java:87)
[15:36:37.945] {ActiveMQ Session Task} at org.apache.activemq.ra.LocalAndXATransaction.begin(LocalAndXATransaction.java:50)
[15:36:37.945] {ActiveMQ Session Task} ... 17 more

Steps To Reproduce

Additional Information

Attached Files

Relationships

Notes
(0003191) ferg 06-12-08 17:10	server/30c4

Issue History
Date Modified	Username	Field	Change
04-25-08 14:10	ferg	New Issue
06-12-08 17:10	ferg	Note Added: 0003191
06-12-08 17:10	ferg	Assigned To	=> ferg
06-12-08 17:10	ferg	Status	new => closed
06-12-08 17:10	ferg	Resolution	open => fixed
06-12-08 17:10	ferg	Fixed in Version	=> 3.2.0

Mantis 1.0.0rc3[^]

28 total queries executed.
25 unique queries executed.