[
https://issues.apache.org/activemq/browse/AMQ-1078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Stalker reopened AMQ-1078:
-------------------------------
Hi,
It appears that there is still a bug some place in the rar.
Here's the scenario:
I recently (ie, a couple days ago) downloaded and built the 4.1 branch, set up
JBoss 4.0.5.GA with a slightly modified activemq-ra.rar (ra.xml modified to
communicate with an external instance of the broker via tcp and setting of
UseInboundSession is set to true...not sure what this does really, but I tried
it as false and the same behavior happens).
Via a persistent queue (oracle backing) I'm consuming messages in an MDB via
the JCA message datasource using XA.
Here's the problem I'm seeing: if I shut down the JMS server, I see the
appropriate EOF exception and subsequent reconnection attempts by the rar in
JBoss. When I startup the external activemq broker again, the connection
appears to get reestablished and work is accepted, started, and
completed...EXCEPT there's no mention of XA and thus the message is never
actually accepted and consumed.
Here's some debug output from the JCA:
PRE shutdown of external broker:
2007-03-09 11:43:02,883 DEBUG [org.apache.activemq.ra.ServerSessionPoolImpl]
ServerSession requested.
2007-03-09 11:43:02,883 DEBUG [org.apache.activemq.ra.ServerSessionPoolImpl]
Using idle session: ServerSessionImpl:1
2007-03-09 11:43:02,883 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
Starting run.
2007-03-09 11:43:02,883 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Work
accepted: [EMAIL PROTECTED]
2007-03-09 11:43:02,883 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Work
started: [EMAIL PROTECTED]
2007-03-09 11:43:02,883 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
Running
2007-03-09 11:43:02,883 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] run
loop start
2007-03-09 11:43:02,884 DEBUG [org.apache.activemq.TransactionContext] Start:
XidImpl[FormatId=257, GlobalId=node118/114, BranchQual=1, localId=114]
2007-03-09 11:43:02,884 DEBUG [org.apache.activemq.TransactionContext] Started
XA transaction: XID:257:6e6f64653131382f313134:31
-- snip -- output of a resulting consumption of message
2007-03-09 11:43:04,447 DEBUG [org.apache.activemq.TransactionContext] End:
XidImpl[FormatId=257, GlobalId=node118/114, BranchQual=1, localId=114]
2007-03-09 11:43:04,447 DEBUG [org.apache.activemq.TransactionContext] Ended XA
transaction: XID:257:6e6f64653131382f313134:31
2007-03-09 11:43:04,448 DEBUG [org.apache.activemq.TransactionContext] Prepare:
XidImpl[FormatId=257, GlobalId=node118/114, BranchQual=1, localId=114]
2007-03-09 11:43:04,454 DEBUG [org.apache.activemq.TransactionContext] Commit:
XidImpl[FormatId=257, GlobalId=node118/114, BranchQual=1, localId=114]
2007-03-09 11:43:05,150 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] run
loop end
2007-03-09 11:43:05,178 DEBUG [org.apache.activemq.ra.ServerSessionPoolImpl]
Session returned to pool: ServerSessionImpl:1
2007-03-09 11:43:05,178 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Run
finished
2007-03-09 11:43:05,178 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Work
completed: [EMAIL PROTECTED]
POST shutdown and restart of external broker
2007-03-09 11:46:33,077 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] Sending: WireFormatInfo {
version=2, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2007-03-09 11:46:33,126 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator] Received WireFormat:
WireFormatInfo { version=2, properties={TightEncodingEnabled=true,
CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
2007-03-09 11:46:33,126 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator]
tcp://seqlims.broad.mit.edu/18.103.10.168:61616 before negotiation:
OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false,
tightEncodingEnabled=false, sizePrefixDisabled=false}
2007-03-09 11:46:33,126 DEBUG
[org.apache.activemq.transport.WireFormatNegotiator]
tcp://seqlims.broad.mit.edu/18.103.10.168:61616 after negotiation:
OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true,
tightEncodingEnabled=true, sizePrefixDisabled=false}
2007-03-09 11:53:15,196 DEBUG [org.apache.activemq.ra.ServerSessionPoolImpl]
ServerSession requested.
2007-03-09 11:53:15,196 DEBUG [org.apache.activemq.ra.ServerSessionPoolImpl]
Using idle session: ServerSessionImpl:1
2007-03-09 11:53:15,196 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
Starting run.
2007-03-09 11:53:15,196 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Work
accepted: [EMAIL PROTECTED]
2007-03-09 11:53:15,196 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Work
started: [EMAIL PROTECTED]
2007-03-09 11:53:15,197 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
Running
-- as you can see, no XA here
2007-03-09 11:53:15,197 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] run
loop start
2007-03-09 11:53:15,197 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] run
loop end
2007-03-09 11:53:15,197 DEBUG [org.apache.activemq.ra.ServerSessionPoolImpl]
Session returned to pool: ServerSessionImpl:1
2007-03-09 11:53:15,197 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Run
finished
2007-03-09 11:53:15,197 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1] Work
completed: [EMAIL PROTECTED]
Thanks for your help!
John
> Messages consumed with the Resource Adapter are intermittently not delivered
> ----------------------------------------------------------------------------
>
> Key: AMQ-1078
> URL: https://issues.apache.org/activemq/browse/AMQ-1078
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker, Connector
> Affects Versions: 4.0
> Reporter: Hiram Chirino
> Assigned To: Hiram Chirino
> Fix For: 4.1.1, 4.2.0
>
> Attachments: AMQ-1078.patch
>
>
> The cause is that the ActiveMQSessionExecutor was starting and using it's
> dispatch thread instead of the Thread managed by the resource adapter.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
