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
