You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by Joey Daughtery <jd...@t-sciences.com> on 2012/06/15 16:36:11 UTC
Thread return from onMessage
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
Re: Thread return from onMessage
Posted by "Weston M. Price" <wp...@redhat.com>.
Hey Joe,
Excellent news.
Weston
On Jun 18, 2012, at 10:22 AM, Joey Daughtery wrote:
> Weston
> After updating the jars in my ear to the version 17 jars, the exception
> went away.
>
> All seems to be working. Thanks for the assistance.
>
> Joe
>
> On Fri, Jun 15, 2012 at 1:35 PM, Weston M. Price <wp...@redhat.com> wrote:
>
>> 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: users-unsubscribe@qpid.apache.org
>> For additional commands, e-mail: users-help@qpid.apache.org
>>
>>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Thread return from onMessage
Posted by Joey Daughtery <jd...@t-sciences.com>.
Weston
After updating the jars in my ear to the version 17 jars, the exception
went away.
All seems to be working. Thanks for the assistance.
Joe
On Fri, Jun 15, 2012 at 1:35 PM, Weston M. Price <wp...@redhat.com> wrote:
> 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: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>
Re: Thread return from onMessage
Posted by "Weston M. Price" <wp...@redhat.com>.
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: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org