Hi Joe,
It appears that the XA transaction cannot complete. Can you give me an
idea of what your code is doing? Based on the exception, you used to see this
when using multiple XAResources from the same broker, but this has since been
fixed. Also, are you still using the Java broker? And finally, it looks like
your using different jars that what you would typically produce by building
from source:
> [qpid-client-0.16.jar:]
This should read qpid-client-0.17.jar
Did you make any modifications beyond what we did yesterday?
Regards,
Weston
On Jun 15, 2012, at 10:36 AM, Joey Daughtery wrote:
> I have been able to deploy the qpid-ra-0.17.rar and post messages to a
> queue and receive those messages with my mdb. However, when the thread
> returns from the MDB onMessage(...) method, I see the exception generated
> below:
>
>
> 09:30:59,240 INFO [stdout] (Dispatcher-0-Conn-51) Merge time: 31 ms.
> 09:31:00,492 INFO [stdout] (Dispatcher-0-Conn-51) Total time: 1305 ms.
> 09:31:00,494 WARN [com.arjuna.ats.jta] (Dispatcher-0-Conn-51)
> ARJUNA016041: pre
> pare on < formatId=131077, gtrid_length=29, bqual_length=36,
> tx_uid=0:ffffc0a801
> 03:11df2b7b:4fdb38f3:13, node_name=1,
> branch_uid=0:ffffc0a80103:11df2b7b:4fdb38f
> 3:14, subordinatenodename=null, eis_name=unknown eis name >
> (org.apache.qpid.cli
> ent.XAResourceImpl@653c33) failed with exception XAException.XA_RBTIMEOUT:
> javax
> .transaction.xa.XAException
> at
> org.apache.qpid.client.XAResourceImpl.checkStatus(XAResourceImpl.java
> :507) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:166) [q
> pid-client-0.16.jar:]
> at
> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
> LevelPrepare(XAResourceRecord.java:208)
> at
> com.arjuna.ats.arjuna.coordinator.BasicAction.doPrepare(BasicAction.j
> ava:2535)
> at
> com.arjuna.ats.arjuna.coordinator.BasicAction.doPrepare(BasicAction.j
> ava:2502)
> at
> com.arjuna.ats.arjuna.coordinator.BasicAction.prepare(BasicAction.jav
> a:2079)
> at
> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
> 72)
> at
> com.arjuna.ats.arjuna.coordinator.TwoPhaseCoordinator.end(TwoPhaseCoo
> rdinator.java:98)
> at com.arjuna.ats.arjuna.AtomicAction.commit(AtomicAction.java:164)
> at
> com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple.c
> ommitAndDisassociate(TransactionImple.java:1165)
> at
> com.arjuna.ats.internal.jta.transaction.arjunacore.BaseTransaction.co
> mmit(BaseTransaction.java:117)
> at
> com.arjuna.ats.jbossatx.BaseTransactionManagerDelegate.commit(BaseTra
> nsactionManagerDelegate.java:75)
> at
> org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.afterDelive
> ry(MessageEndpointInvocationHandler.java:72)
> [jboss-as-ejb3-7.1.1.Final.jar:7.1.
> 1.Final]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> [rt.jar:1
> .6.0_25]
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.
> java:39) [rt.jar:1.6.0_25]
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAcces
> sorImpl.java:25) [rt.jar:1.6.0_25]
> at java.lang.reflect.Method.invoke(Method.java:597)
> [rt.jar:1.6.0_25]
> at
> org.jboss.as.ejb3.inflow.AbstractInvocationHandler.handle(AbstractInv
> ocationHandler.java:60) [jboss-as-ejb3-7.1.1.Final.jar:7.1.1.Final]
> at
> org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.doInvoke(Me
> ssageEndpointInvocationHandler.java:136) [jboss-as-ejb3-7.1.1.Final.jar:
> 7.1.1.Fi
> nal]
> at
> org.jboss.as.ejb3.inflow.AbstractInvocationHandler.invoke(AbstractInv
> ocationHandler.java:73) [jboss-as-ejb3-7.1.1.Final.jar:7.1.1.Final]
> at $Proxy16.afterDelivery(Unknown Source) at
> org.apache.qpid.ra.in
> flow.QpidMessageHandler.onMessage(QpidMessageHandler.java:217)
> at
> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
> eConsumer.java:751) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
> essageConsumer_0_10.java:141) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
> eConsumer.java:725) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
> essageConsumer_0_10.java:186) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
> essageConsumer_0_10.java:54) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
> n.java:3475) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
> on.java:3414) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
> ava:3201) [qpid-client-0.16.jar:]
> at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
> [qpi
> d-client-0.16.jar:]
> at
> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
> dMessage.java:54) [qpid-client-0.16.jar:]
> at
> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
> ) [qpid-client-0.16.jar:]
> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>
> 09:31:00,563 WARN [com.arjuna.ats.arjuna] (Dispatcher-0-Conn-51)
> ARJUNA012073:
> BasicAction.End() - prepare phase of action-id
> 0:ffffc0a80103:11df2b7b:4fdb38f3:
> 13 failed.
> 09:31:00,564 WARN [com.arjuna.ats.arjuna] (Dispatcher-0-Conn-51)
> ARJUNA012075:
> Action Aborting
> 09:31:00,567 INFO [org.apache.qpid.client.AMQConnection] (IoReceiver -
> /127.0.0
> .1:5672) Closing AMQConnection due to :org.apache.qpid.AMQException: ch=1
> id=4 E
> xecutionException(errorCode=ILLEGAL_STATE, commandId=14, description=Xid
> Xid(for
> mat=131077, globalId=[B@1343e2f, branchId=[B@de8d9d) not associated with
> the cur
> rent session) [error code 409: argument invalid]
> 09:31:00,570 WARN [org.apache.qpid.ra.inflow.QpidExceptionHandler]
> (IoReceiver
> - /127.0.0.1:5672) Failure in Qpid activation
> org.apache.qpid.ra.inflow.QpidActi
> vationSpec(ra=org.apache.qpid.ra.QpidResourceAdapter@17e6153destination=java:jb
> oss/exported/iHarvestQueue destinationType=javax.jms.Queue
> ack=Auto-acknowledge
> durable=false clientID=null user=null maxSession=10
> connectionPerHandler=true):
> javax.jms.JMSException: Exception thrown against AMQConnection:
> Host: 127.0.0.1
> Port: 5672
> Virtual Host: test
> Client ID: client_id
> Active session count: 1: org.apache.qpid.AMQException: ch=1 id=4
> ExecutionExcept
> ion(errorCode=ILLEGAL_STATE, commandId=14, description=Xid
> Xid(format=131077, gl
> obalId=[B@1343e2f, branchId=[B@de8d9d) not associated with the current
> session)
> [error code 409: argument invalid]
> at
> org.apache.qpid.client.AMQConnection.exceptionReceived(AMQConnection.
> java:1226)
> at
> org.apache.qpid.client.AMQSession_0_10.setCurrentException(AMQSession
> _0_10.java:1057)
> at
> org.apache.qpid.client.AMQSession_0_10.exception(AMQSession_0_10.java
> :907)
> at
> org.apache.qpid.transport.SessionDelegate.executionException(SessionD
> elegate.java:182)
> at
> org.apache.qpid.transport.SessionDelegate.executionException(SessionD
> elegate.java:32)
> at
> org.apache.qpid.transport.ExecutionException.dispatch(ExecutionExcept
> ion.java:103)
> at
> org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.jav
> a:55)
> at
> org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.jav
> a:50)
> at
> org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.jav
> a:32)
> at org.apache.qpid.transport.Method.delegate(Method.java:159)
> at org.apache.qpid.transport.Session.received(Session.java:584)
> at
> org.apache.qpid.transport.Connection.dispatch(Connection.java:421)
> at
> org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegat
> e.java:64)
> at
> org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegat
> e.java:40)
> at
> org.apache.qpid.transport.MethodDelegate.executionException(MethodDel
> egate.java:110)
> at
> org.apache.qpid.transport.ExecutionException.dispatch(ExecutionExcept
> ion.java:103)
> at
> org.apache.qpid.transport.ConnectionDelegate.command(ConnectionDelega
> te.java:54)
> at
> org.apache.qpid.transport.ConnectionDelegate.command(ConnectionDelega
> te.java:40)
> at org.apache.qpid.transport.Method.delegate(Method.java:159)
> at
> org.apache.qpid.transport.Connection.received(Connection.java:376)
> at org.apache.qpid.transport.Connection.received(Connection.java:67)
> at
> org.apache.qpid.transport.network.Assembler.emit(Assembler.java:97)
> at
> org.apache.qpid.transport.network.Assembler.assemble(Assembler.java:1
> 98)
> at
> org.apache.qpid.transport.network.Assembler.frame(Assembler.java:131)
>
> at org.apache.qpid.transport.network.Frame.delegate(Frame.java:128)
> at
> org.apache.qpid.transport.network.Assembler.received(Assembler.java:1
> 02)
> at
> org.apache.qpid.transport.network.Assembler.received(Assembler.java:4
> 4)
> at
> org.apache.qpid.transport.network.InputHandler.next(InputHandler.java
> :189)
> at
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.
> java:105)
> at
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.
> java:44)
> at
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:1
> 52)
> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
> Caused by: org.apache.qpid.AMQException: ch=1 id=4
> ExecutionException(errorCode=
> ILLEGAL_STATE, commandId=14, description=Xid Xid(format=131077,
> globalId=[B@1343
> e2f, branchId=[B@de8d9d) not associated with the current session) [error
> code 40
> 9: argument invalid]
> at
> org.apache.qpid.client.AMQSession_0_10.setCurrentException(AMQSession
> _0_10.java:1054)
> ... 30 more
>
> 09:31:02,488 INFO [com.tst.iharvest.model.backend.SimilarityScoring]
> (Thread-26
> 9) Processing (2, 3).
> 09:31:05,637 INFO [org.apache.qpid.ra.inflow.QpidExceptionHandler]
> (IoReceiver
> - /127.0.0.1:5672) Attempting to reconnect
> org.apache.qpid.ra.inflow.QpidActivat
> ionSpec(ra=org.apache.qpid.ra.QpidResourceAdapter@17e6153destination=java:jboss
> /exported/iHarvestQueue destinationType=javax.jms.Queue
> ack=Auto-acknowledge dur
> able=false clientID=null user=null maxSession=10 connectionPerHandler=true)
> 09:31:05,659 INFO [org.apache.qpid.transport.ClientDelegate] (IoReceiver -
> /127
> .0.0.1:5672) The broker does not support the configured connection idle
> timeout
> of 120 sec, using the brokers max supported value of 0 sec instead.
> 09:31:05,662 INFO [org.apache.qpid.client.AMQConnection] (IoReceiver -
> /127.0.0
> .1:5672) Connection 62 now connected from /127.0.0.1:50644 to /
> 127.0.0.1:5672
> 09:31:05,666 INFO [org.apache.qpid.ra.inflow.QpidExceptionHandler]
> (IoReceiver
> - /127.0.0.1:5672) Reconnected with Qpid
>
> Thanks
>
> Joe
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
