9:03 a.m.
[
https://issues.jboss.org/browse/JBTM-1951?page=com.atlassian.jira.plugin....
]
Peter Klauser commented on JBTM-1951:
-------------------------------------
Our code doing inbound MDB handling is a TimerTask which is scheduled to repeatedly run..
public void run()
{
log.info("AQ JCA - inbound dequeue thread started.");
MessageEndpoint endpoint = null;
shutdownRequest.set(false);
try {
initializeConnection(); // -- this is an oracle AQ connection > nothing to do with
JCA/JDBC
MessageEndpointFactory endpointFactory = activation.getMessageEndpointFactory();
endpoint = endpointFactory.createEndpoint(xaResource);
dequeueOption = new AQDequeueOption();
while (!shutdownRequest.get()) {
try {
endpoint.beforeDelivery(AqActivation.ONMESSAGE);
AqMessage aqMessage = AqUtils.dequeue(getQueue(),
getConfig().isSupportMessageSplit(), dequeueOption, getConfig().getCorrelationId(),
getConfig().getDequeueTimeout());
dispatchRequest(endpoint, aqMessage);
} catch (AQException e) {
if (AqUtils.isEndOfQueueExcepion(e)) {
// ignore timeout
log.info("EOQE - nothing on the queue " + getQueue().getName());
} else {
log.error("AqException during dequeue:" + e, e);
shutdownRequest.set(true);
}
} catch (Throwable e) {
log.error("Handling Exception", e);
shutdownRequest.set(true);
} finally {
try{
endpoint.afterDelivery();
} catch(Exception rex){
log.error("Exception in afterDelivery(): ", rex);
shutdownRequest.set(true);
}
}
}
closeConnection(); // -- close the oracle AQ connection
if ( endpoint != null ) {
endpoint.release();
}
} catch ( Throwable t ) {
log.error("AQRA encountered runtime exception.", t);
} finally {
closeConnection(); // -- make sure the AQ connection is closed when the thread leaves.
}
}
Deadlock in JBOSS Transaction Reaper
------------------------------------
Key: JBTM-1951
URL: https://issues.jboss.org/browse/JBTM-1951
Project: JBoss Transaction Manager
Issue Type: Bug
Security Level: Public(Everyone can see)
Affects Versions: 4.16.2
Reporter: Peter Klauser
Assignee: Tom Jenkinson
Found one Java-level deadlock:
=============================
"Timer-93":
waiting to lock monitor 0x00007f8fac190cf8 (object 0x00000000d6d50830, a
com.arjuna.ats.internal.jta.transaction.arjunacore.AtomicAction),
which is held by "Transaction Reaper Worker 0"
"Transaction Reaper Worker 0":
waiting for ownable synchronizer 0x00000000d6861408, (a
java.util.concurrent.locks.ReentrantLock$FairSync),
which is held by "Timer-93"
Java stack information for the threads listed above:
===================================================
"Timer-93":
at com.arjuna.ats.arjuna.coordinator.BasicAction.Abort(BasicAction.java:1573)
- waiting to lock <0x00000000d6d50830> (a
com.arjuna.ats.internal.jta.transaction.arjunacore.AtomicAction)
at
com.arjuna.ats.arjuna.coordinator.TwoPhaseCoordinator.cancel(TwoPhaseCoordinator.java:118)
at com.arjuna.ats.arjuna.AtomicAction.abort(AtomicAction.java:188)
at
com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple.rollbackAndDisassociate(TransactionImple.java:1247)
at
com.arjuna.ats.internal.jta.transaction.arjunacore.BaseTransaction.rollback(BaseTransaction.java:134)
at
com.arjuna.ats.jbossatx.BaseTransactionManagerDelegate.rollback(BaseTransactionManagerDelegate.java:114)
at
org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.afterDelivery(MessageEndpointInvocationHandler.java:70)
at sun.reflect.GeneratedMethodAccessor1756.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at
org.jboss.as.ejb3.inflow.AbstractInvocationHandler.handle(AbstractInvocationHandler.java:60)
at
org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.doInvoke(MessageEndpointInvocationHandler.java:136)
at
org.jboss.as.ejb3.inflow.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:73)
at com.sun.proxy.$Proxy852.afterDelivery(Unknown Source)
at sunrise.ra.aq.inbound.AqServerSession.run(AqServerSession.java:141)
at java.util.TimerThread.mainLoop(Unknown Source)
at java.util.TimerThread.run(Unknown Source)
"Transaction Reaper Worker 0":
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000000d6861408> (a
java.util.concurrent.locks.ReentrantLock$FairSync)
at java.util.concurrent.locks.LockSupport.park(Unknown Source)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(Unknown
Source)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(Unknown Source)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(Unknown Source)
at java.util.concurrent.locks.ReentrantLock$FairSync.lock(Unknown Source)
at java.util.concurrent.locks.ReentrantLock.lock(Unknown Source)
at
org.jboss.jca.adapters.jdbc.BaseWrapperManagedConnection.lock(BaseWrapperManagedConnection.java:361)
at org.jboss.jca.adapters.jdbc.xa.XAManagedConnection.end(XAManagedConnection.java:290)
at
org.jboss.jca.core.tx.jbossts.XAResourceWrapperImpl.end(XAResourceWrapperImpl.java:99)
at
com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.topLevelAbort(XAResourceRecord.java:312)
at com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.java:2874)
at com.arjuna.ats.arjuna.coordinator.BasicAction.doAbort(BasicAction.java:2853)
at com.arjuna.ats.arjuna.coordinator.BasicAction.Abort(BasicAction.java:1616)
- locked <0x00000000d6d50830> (a
com.arjuna.ats.internal.jta.transaction.arjunacore.AtomicAction)
at
com.arjuna.ats.arjuna.coordinator.TwoPhaseCoordinator.cancel(TwoPhaseCoordinator.java:118)
at com.arjuna.ats.arjuna.AtomicAction.cancel(AtomicAction.java:217)
at
com.arjuna.ats.arjuna.coordinator.TransactionReaper.doCancellations(TransactionReaper.java:370)
at
com.arjuna.ats.internal.arjuna.coordinator.ReaperWorkerThread.run(ReaperWorkerThread.java:78)
Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
4104
days inactive
4104
days old
jbossts-issues@lists.jboss.org
0 comments
1 participants
participants (1)
-
Peter Klauser (JIRA)