Hi Joe,
Well, there are a few things we can tune:
1) On the outbound, or 'producer' side, we have a ton of tuning options in
terms of connection pools, idle-timeout on the pool, advanced reaping of
connections etc. The AS7 JCA schema is the best place to start, we can discuss
this off-list to see where those settings might make sense.
2) On the inbound, or 'consuming' side, we have a few options in terms of
session count, etc.
The thing that concerns me is where the error is occurring: it's in the XA code
which usually means something is timing out during the 2PC (two phase commit)
protocol. From the trace you posted, there seems to be a lot of latency between
the transaction manager and the resource manager (Qpid). Also, could you
describe what it is your actually doing in your code?
Regards,
Weston
On Jun 19, 2012, at 3:24 PM, Joey Daughtery wrote:
> Weston
> Yes, it is straight out of the box, default settings. I will look for
> those settings.
>
> I believe the type of testing that I am currently doing, which is simply
> flooding it will never really occur.
>
> Thanks
>
> Joe
>
> On Tue, Jun 19, 2012 at 12:35 PM, Weston M. Price <[email protected]> wrote:
>
>> Hi Joe,
>> This typically means you have exhausted the available connection
>> pool or listening pool. Are you using the default settings? I don't believe
>> we tuned anything specifically for your usage patterns.
>>
>> Regards,
>>
>> Weston
>> On Jun 19, 2012, at 12:03 PM, Joey Daughtery wrote:
>>
>>> All
>>> After running 45,000 records through the system, I started seeing the
>>> following exception:
>>>
>>> 10:59:21,450 INFO [stdout] (Dispatcher-0-Conn-6) Merge time: 0 ms.
>>> 10:59:21,454 INFO [stdout] (Dispatcher-0-Conn-6) Total time: 90 ms.
>>> 10:59:27,894 WARN [com.arjuna.ats.jta] (Dispatcher-0-Conn-10)
>>> ARJUNA016045: att
>>> empted rollback of < formatId=131077, gtrid_length=29, bqual_length=36,
>>> tx_uid=0
>>> :ffffc0a80103:4517144c:4fe0897c:7fc6e, node_name=1,
>>> branch_uid=0:ffffc0a80103:45
>>> 17144c:4fe0897c:7fc6f, subordinatenodename=null, eis_name=unknown eis
>> name
>>>> (or
>>> g.apache.qpid.client.XAResourceImpl@130f3f5) failed with exception code
>> -:
>>> org.a
>>> pache.qpid.transport.SessionException: timed out waiting for session to
>>> become o
>>> pen (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153) [qpid-common-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162) [q
>>> pid-client-0.17.jar:]
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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 $Proxy15.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.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201) [qpid-client-0.17.jar:]
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> [qpi
>>> d-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> ) [qpid-client-0.17.jar:]
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:27,929 ERROR [org.apache.qpid.ra.inflow.QpidMessageHandler]
>>> (Dispatcher-0-
>>> Conn-10) Failed to deliver message:
>>> org.apache.qpid.transport.SessionException:
>>> timed out waiting for session to become open (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153)
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93)
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162)
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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)
>>> at sun.reflect.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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)
>>> at
>>> org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.doInvoke(Me
>>> ssageEndpointInvocationHandler.java:136)
>>> at
>>> org.jboss.as.ejb3.inflow.AbstractInvocationHandler.invoke(AbstractInv
>>> ocationHandler.java:73)
>>> at $Proxy15.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)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:27,954 ERROR [org.apache.qpid.client.BasicMessageConsumer]
>>> (Dispatcher-0-C
>>> onn-10) reNotification : Caught exception (dump follows) - ignoring...:
>>> java.lan
>>> g.IllegalArgumentException: range exceeds max received command-id:
>> [21775,
>>> 21775
>>> ]
>>> at org.apache.qpid.transport.Session.processed(Session.java:459)
>>> at org.apache.qpid.transport.Session.processed(Session.java:439)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushProcessed(AMQSession_0_10
>>> .java:312)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.messageAcknowledge(AMQSession_
>>> 0_10.java:295)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:280)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:271)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.acknowledgeMessage(AMQSession_
>>> 0_10.java:265)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.postDeliver(BasicMessageC
>>> onsumer.java:815)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.postDeliver(BasicMes
>>> sageConsumer_0_10.java:426)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:752)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:27,968 INFO [com.tst.iharvest.metadata.task.TaskDragon]
>>> (Dispatcher-0-Con
>>> n-2) Received message:
>>> {"geoactivity":{"latitude":"38.952005000164746","longitud
>>>
>> e":"-76.96829702276297","altitude":"4938.804549272015","north":"38.9659873677477
>>>
>> 4","east":"-76.93422223943777","south":"38.93801987359443","west":"-77.002371806
>>>
>> 08815","zoomlevel":"15","classification":"unclassified"},"visible":[],"count":"0
>>> ","date":"2012-06-19
>>> 10:57:17.974","event":"geoview","classification":"unclassif
>>> ied"}
>>> 10:59:27,971 WARN [com.arjuna.ats.jta] (Dispatcher-0-Conn-12)
>>> ARJUNA016045: att
>>> empted rollback of < formatId=131077, gtrid_length=29, bqual_length=36,
>>> tx_uid=0
>>> :ffffc0a80103:4517144c:4fe0897c:7fc7a, node_name=1,
>>> branch_uid=0:ffffc0a80103:45
>>> 17144c:4fe0897c:7fc7b, subordinatenodename=null, eis_name=unknown eis
>> name
>>>> (or
>>> g.apache.qpid.client.XAResourceImpl@e8965a) failed with exception code
>> -:
>>> org.ap
>>> ache.qpid.transport.SessionException: timed out waiting for session to
>>> become op
>>> en (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153) [qpid-common-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162) [q
>>> pid-client-0.17.jar:]
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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 $Proxy15.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.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201) [qpid-client-0.17.jar:]
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> [qpi
>>> d-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> ) [qpid-client-0.17.jar:]
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:28,030 ERROR [org.apache.qpid.ra.inflow.QpidMessageHandler]
>>> (Dispatcher-0-
>>> Conn-12) Failed to deliver message:
>>> org.apache.qpid.transport.SessionException:
>>> timed out waiting for session to become open (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153)
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93)
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162)
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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)
>>> at sun.reflect.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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)
>>> at
>>> org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.doInvoke(Me
>>> ssageEndpointInvocationHandler.java:136)
>>> at
>>> org.jboss.as.ejb3.inflow.AbstractInvocationHandler.invoke(AbstractInv
>>> ocationHandler.java:73)
>>> at $Proxy15.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)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:28,045 INFO [stdout] (Dispatcher-0-Conn-2) Merge time: 0 ms.
>>> 10:59:28,049 INFO [stdout] (Dispatcher-0-Conn-2) Total time: 78 ms.
>>> 10:59:28,066 ERROR [org.apache.qpid.client.BasicMessageConsumer]
>>> (Dispatcher-0-C
>>> onn-12) reNotification : Caught exception (dump follows) - ignoring...:
>>> java.lan
>>> g.IllegalArgumentException: range exceeds max received command-id: [6685,
>>> 6685]
>>> at org.apache.qpid.transport.Session.processed(Session.java:459)
>>> at org.apache.qpid.transport.Session.processed(Session.java:439)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushProcessed(AMQSession_0_10
>>> .java:312)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.messageAcknowledge(AMQSession_
>>> 0_10.java:295)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:280)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:271)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.acknowledgeMessage(AMQSession_
>>> 0_10.java:265)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.postDeliver(BasicMessageC
>>> onsumer.java:815)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.postDeliver(BasicMes
>>> sageConsumer_0_10.java:426)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:752)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:28,084 INFO [com.tst.iharvest.metadata.task.TaskDragon]
>>> (Dispatcher-0-Con
>>> n-2) Received message: {"visible":[],"query":"james
>>> neal","count":"0","date":"20
>>> 12-06-19 10:57:18.063","event":"query","classification":"unclassified"}
>>> 10:59:28,149 INFO [stdout] (Dispatcher-0-Conn-2) Merge time: 0 ms.
>>> 10:59:28,152 INFO [stdout] (Dispatcher-0-Conn-2) Total time: 67 ms.
>>> 10:59:37,025 WARN [com.arjuna.ats.jta] (Dispatcher-0-Conn-14)
>>> ARJUNA016045: att
>>> empted rollback of < formatId=131077, gtrid_length=29, bqual_length=36,
>>> tx_uid=0
>>> :ffffc0a80103:4517144c:4fe0897c:80172, node_name=1,
>>> branch_uid=0:ffffc0a80103:45
>>> 17144c:4fe0897c:80173, subordinatenodename=null, eis_name=unknown eis
>> name
>>>> (or
>>> g.apache.qpid.client.XAResourceImpl@16ef93f) failed with exception code
>> -:
>>> org.a
>>> pache.qpid.transport.SessionException: timed out waiting for session to
>>> become o
>>> pen (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153) [qpid-common-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162) [q
>>> pid-client-0.17.jar:]
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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 $Proxy15.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.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201) [qpid-client-0.17.jar:]
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> [qpi
>>> d-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> ) [qpid-client-0.17.jar:]
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:37,058 ERROR [org.apache.qpid.ra.inflow.QpidMessageHandler]
>>> (Dispatcher-0-
>>> Conn-14) Failed to deliver message:
>>> org.apache.qpid.transport.SessionException:
>>> timed out waiting for session to become open (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153)
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93)
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162)
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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)
>>> at sun.reflect.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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)
>>> at
>>> org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.doInvoke(Me
>>> ssageEndpointInvocationHandler.java:136)
>>> at
>>> org.jboss.as.ejb3.inflow.AbstractInvocationHandler.invoke(AbstractInv
>>> ocationHandler.java:73)
>>> at $Proxy15.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)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:37,092 ERROR [org.apache.qpid.client.BasicMessageConsumer]
>>> (Dispatcher-0-C
>>> onn-14) reNotification : Caught exception (dump follows) - ignoring...:
>>> java.lan
>>> g.IllegalArgumentException: range exceeds max received command-id: [20,
>> 20]
>>> at org.apache.qpid.transport.Session.processed(Session.java:459)
>>> at org.apache.qpid.transport.Session.processed(Session.java:439)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushProcessed(AMQSession_0_10
>>> .java:312)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.messageAcknowledge(AMQSession_
>>> 0_10.java:295)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:280)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:271)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.acknowledgeMessage(AMQSession_
>>> 0_10.java:265)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.postDeliver(BasicMessageC
>>> onsumer.java:815)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.postDeliver(BasicMes
>>> sageConsumer_0_10.java:426)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:752)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:37,109 INFO [com.tst.iharvest.metadata.task.TaskDragon]
>>> (Dispatcher-0-Con
>>> n-2) Received message: {"visible":[],"query":"tiffany
>>> rubin","count":"0","date":
>>> "2012-06-19
>> 10:57:36.229","event":"query","classification":"unclassified"}
>>> 10:59:37,188 INFO [stdout] (Dispatcher-0-Conn-2) Merge time: 0 ms.
>>> 10:59:37,203 INFO [stdout] (Dispatcher-0-Conn-2) Total time: 92 ms.
>>> 10:59:37,434 WARN [com.arjuna.ats.jta] (Dispatcher-0-Conn-15)
>>> ARJUNA016045: att
>>> empted rollback of < formatId=131077, gtrid_length=29, bqual_length=36,
>>> tx_uid=0
>>> :ffffc0a80103:4517144c:4fe0897c:8017e, node_name=1,
>>> branch_uid=0:ffffc0a80103:45
>>> 17144c:4fe0897c:8017f, subordinatenodename=null, eis_name=unknown eis
>> name
>>>> (or
>>> g.apache.qpid.client.XAResourceImpl@beae43) failed with exception code
>> -:
>>> org.ap
>>> ache.qpid.transport.SessionException: timed out waiting for session to
>>> become op
>>> en (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> [qpid-comm
>>> on-0.17.jar:]
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153) [qpid-common-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162) [q
>>> pid-client-0.17.jar:]
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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 $Proxy15.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.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201) [qpid-client-0.17.jar:]
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> [qpi
>>> d-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54) [qpid-client-0.17.jar:]
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> ) [qpid-client-0.17.jar:]
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:37,470 ERROR [org.apache.qpid.ra.inflow.QpidMessageHandler]
>>> (Dispatcher-0-
>>> Conn-15) Failed to deliver message:
>>> org.apache.qpid.transport.SessionException:
>>> timed out waiting for session to become open (state=NEW)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:676)
>>> at org.apache.qpid.transport.Session.invoke(Session.java:615)
>>> at
>>> org.apache.qpid.transport.SessionInvoker.dtxSelect(SessionInvoker.jav
>>> a:153)
>>> at
>>> org.apache.qpid.client.XASessionImpl.createSession(XASessionImpl.java
>>> :93)
>>> at
>>> org.apache.qpid.client.XAResourceImpl.end(XAResourceImpl.java:162)
>>> at
>>> com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.top
>>> LevelAbort(XAResourceRecord.java:312)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2874)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.jav
>>> a:2853)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.phase2Abort(BasicAction
>>> .java:1908)
>>> at
>>> com.arjuna.ats.arjuna.coordinator.BasicAction.End(BasicAction.java:14
>>> 85)
>>> 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)
>>> at sun.reflect.GeneratedMethodAccessor10.invoke(Unknown Source)
>>> [: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)
>>> at
>>> org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.doInvoke(Me
>>> ssageEndpointInvocationHandler.java:136)
>>> at
>>> org.jboss.as.ejb3.inflow.AbstractInvocationHandler.invoke(AbstractInv
>>> ocationHandler.java:73)
>>> at $Proxy15.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)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:37,513 ERROR [org.apache.qpid.client.BasicMessageConsumer]
>>> (Dispatcher-0-C
>>> onn-15) reNotification : Caught exception (dump follows) - ignoring...:
>>> java.lan
>>> g.IllegalArgumentException: range exceeds max received command-id: [20,
>> 20]
>>> at org.apache.qpid.transport.Session.processed(Session.java:459)
>>> at org.apache.qpid.transport.Session.processed(Session.java:439)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushProcessed(AMQSession_0_10
>>> .java:312)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.messageAcknowledge(AMQSession_
>>> 0_10.java:295)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:280)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.flushAcknowledgments(AMQSessio
>>> n_0_10.java:271)
>>> at
>>> org.apache.qpid.client.AMQSession_0_10.acknowledgeMessage(AMQSession_
>>> 0_10.java:265)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.postDeliver(BasicMessageC
>>> onsumer.java:815)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.postDeliver(BasicMes
>>> sageConsumer_0_10.java:426)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:752)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:141)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessag
>>> eConsumer.java:725)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:186)
>>> at
>>> org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicM
>>> essageConsumer_0_10.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSessio
>>> n.java:3475)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSessi
>>> on.java:3414)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.j
>>> ava:3201)
>>> at
>> org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3194)
>>> at
>>> org.apache.qpid.client.message.UnprocessedMessage.dispatch(Unprocesse
>>> dMessage.java:54)
>>> at
>>> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3337
>>> )
>>> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_25]
>>>
>>> 10:59:37,531 INFO [com.tst.iharvest.metadata.task.TaskDragon]
>>> (Dispatcher-0-Con
>>> n-2) Received message:
>>> {"geoactivity":{"latitude":"39.58417388792475","longitude
>>>
>> ":"-105.02446432328762","altitude":"4857.833769250299","north":"39.5980306740427
>>>
>> 4","east":"-104.99038953996242","south":"39.57031433044462","west":"-105.0585391
>>>
>> 066128","zoomlevel":"15","classification":"unclassified"},"visible":[],"count":"
>>> 0","date":"2012-06-19
>>> 10:57:36.437","event":"geoview","classification":"unclassi
>>> fied"}
>>> 10:59:37,594 INFO [stdout] (Dispatcher-0-Conn-2) Merge time: 0 ms.
>>> 10:59:37,597 INFO [stdout] (Dispatcher-0-Conn-2) Total time: 63 ms.
>>
>>
>> ---------------------------------------------------------------------
>> 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]
