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 <[email protected]> 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: [email protected]
>> For additional commands, e-mail: [email protected]
>>
>>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
