StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

POHornetQ: How to reuse XAConnection and XASession
text
Body
copied!<p>I'm facing some issues trying to reuse a XAConnection and XASession on multiple workers in my JBoss application. I've managed simplify the issue down to just one single method. It should be able to both <em>Produce</em> and <em>Consumer</em> a message using the same connection and session. Currently my application has a lot of queues and workers, where each worker is currently initiating and starting each own connection and session, instead of sharing it. Shouldn't that be possible?</p> <p>Here is my code example:</p> <pre><code>import org.apache.log4j.Logger; import javax.annotation.PostConstruct; import javax.annotation.PreDestroy; import javax.ejb.Singleton; import javax.ejb.Startup; import javax.jms.*; import javax.jms.Queue; import javax.naming.InitialContext; @Singleton @Startup public class QueueTest { private Logger logger = Logger.getLogger(QueueTest.class); @PostConstruct public void startup() { try { String queue = "queue/Queue1"; String message = "test"; //setting up connection InitialContext iniCtx = new InitialContext(); XAConnectionFactory qcf = (XAConnectionFactory) iniCtx.lookup("java:/JmsXA"); XAConnection connection = qcf.createXAConnection(); connection.start(); logger.debug("creating connection at " + new java.util.Date()); //setting up session XASession session = connection.createXASession(); logger.debug("creating session at " + new java.util.Date()); //find the queue Object queueObj = iniCtx.lookup(queue); Queue jmsQueue = (javax.jms.Queue)queueObj; //adding message to queue javax.jms.MessageProducer producer = session.createProducer(jmsQueue); javax.jms.TextMessage textMessage = session.createTextMessage(message); producer.send(textMessage); producer.close(); logger.debug("Message added to queue"); //receiving message from queue javax.jms.MessageConsumer consumer = session.createConsumer(jmsQueue); javax.jms.TextMessage messageReceived = (javax.jms.TextMessage)consumer.receive(5000); if (messageReceived==null) throw new Exception("No message reveived"); logger.debug("Got message:"+messageReceived.getText()); consumer.close(); } catch(Exception e) { logger.debug("Error: " + e.getMessage(), e); } } @PreDestroy public void shutdown() { } } </code></pre> <p>It results in this output:</p> <pre><code>11:47:17,905 DEBUG [QueueTest] (MSC service thread 1-8) creating connection at Thu Sep 05 11:47:17 CEST 2013 11:47:18,041 DEBUG [QueueTest] (MSC service thread 1-8) creating session at Thu Sep 05 11:47:18 CEST 2013 11:47:18,065 DEBUG [QueueTest] (MSC service thread 1-8) Message added to queue 11:47:23,081 DEBUG [QueueTest] (MSC service thread 1-8) Error: No message reveived </code></pre> <p>As you can see, no message is received by the <em>Consumer</em>. Why?</p> <p><strong>EDIT 1:</strong></p> <pre><code>package dk.energimidt.uapi.zigbee.services; import org.apache.log4j.Logger; import javax.ejb.Stateless; import javax.ejb.TransactionAttribute; import javax.ejb.TransactionAttributeType; import javax.jms.Queue; import javax.jms.XAConnection; import javax.jms.XAConnectionFactory; import javax.jms.XASession; import javax.naming.InitialContext; @TransactionAttribute(TransactionAttributeType.REQUIRED) @Stateless public class QueueTestWorkerBean implements QueueTestWorker { private Logger logger = Logger.getLogger(QueueTestWorkerBean.class); public void run() { try { String queue = "queue/Queue1"; String message = "test"; //setting up connection InitialContext iniCtx = new InitialContext(); XAConnectionFactory qcf = (XAConnectionFactory) iniCtx.lookup("java:/JmsXA"); XAConnection connection = qcf.createXAConnection(); connection.start(); logger.debug("creating connection at " + new java.util.Date()); //setting up session XASession session = connection.createXASession(); logger.debug("creating session at " + new java.util.Date()); //find the queue Object queueObj = iniCtx.lookup(queue); Queue jmsQueue = (javax.jms.Queue)queueObj; //adding message to queue javax.jms.MessageProducer producer = session.createProducer(jmsQueue); javax.jms.TextMessage textMessage = session.createTextMessage(message); producer.send(textMessage); producer.close(); session.commit(); logger.debug("Message added to queue"); //receiving message from queue javax.jms.MessageConsumer consumer = session.createConsumer(jmsQueue); javax.jms.TextMessage messageReceived = (javax.jms.TextMessage)consumer.receive(5000); if (messageReceived==null) throw new Exception("No message reveived"); logger.debug("Got message:"+messageReceived.getText()); consumer.close(); connection.close(); } catch(Exception e) { logger.debug("Error: " + e.getMessage(), e); } } } </code></pre> <p>Now I get an exception on the <em>Session.Commit()</em>:</p> <pre><code>10:46:03,697 DEBUG [QueueTestWorkerBean] (MSC service thread 1-14) creating connection at Tue Sep 17 10:46:03 CEST 2013 10:46:04,343 DEBUG [QueueTestWorkerBean] (MSC service thread 1-14) creating session at Tue Sep 17 10:46:04 CEST 2013 10:46:04,355 DEBUG [QueueTestWorkerBean] (MSC service thread 1-14) Error: XA connection: javax.jms.TransactionInProgressException: XA connection at org.hornetq.ra.HornetQRASession.commit(HornetQRASession.java:386) at QueueTestWorkerBean.run(QueueTestWorkerBean.java:45) [library-1.0.0.jar:] </code></pre>

Querying!

Guidance

An individual column

Larger individual text columns get their own page to allow for proper reading.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload