You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@artemis.apache.org by "Justin Bertram (Jira)" <ji...@apache.org> on 2026/05/16 15:53:00 UTC

[jira] [Created] (ARTEMIS-6066) Deadlock with FederatedQueueConsumerImpl

Justin Bertram created ARTEMIS-6066:
---------------------------------------

             Summary: Deadlock with FederatedQueueConsumerImpl
                 Key: ARTEMIS-6066
                 URL: https://issues.apache.org/jira/browse/ARTEMIS-6066
             Project: Artemis
          Issue Type: Task
            Reporter: Justin Bertram
            Assignee: Justin Bertram


This deadlock was observed when using Core federation:
{noformat}
Found one Java-level deadlock:
=============================
"Thread-0 (ActiveMQ-scheduled-threads)":
  waiting to lock monitor 0x00007f503040aa60 (object 0x000000052d4ec878, a java.lang.Object),
  which is held by "Thread-4 (ActiveMQ-scheduled-threads)"

"Thread-4 (ActiveMQ-scheduled-threads)":
  waiting for ownable synchronizer 0x000000052dac7a80, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
  which is held by "Thread-4723 (ActiveMQ-client-global-threads)"

"Thread-4723 (ActiveMQ-client-global-threads)":
  waiting to lock monitor 0x00007f503040aa60 (object 0x000000052d4ec878, a java.lang.Object),
  which is held by "Thread-4 (ActiveMQ-scheduled-threads)"

Java stack information for the threads listed above:
===================================================
"Thread-0 (ActiveMQ-scheduled-threads)":
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.interruptConnectAndCloseAllSessions(ClientSessionFactoryImpl.java:486)
	- waiting to lock <0x000000052d4ec878> (a java.lang.Object)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.cleanup(ClientSessionFactoryImpl.java:527)
	at org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl.connect(FederatedQueueConsumerImpl.java:161)
	- locked <0x00000005248be880> (a org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl)
	at org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl.lambda$scheduleConnect$0(FederatedQueueConsumerImpl.java:122)
	at org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl$$Lambda$992/0x00007f5158686000.run(Unknown Source)
	at java.util.concurrent.Executors$RunnableAdapter.call(java.base@17.0.18/Executors.java:539)
	at java.util.concurrent.FutureTask.run(java.base@17.0.18/FutureTask.java:264)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(java.base@17.0.18/ScheduledThreadPoolExecutor.java:304)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@17.0.18/ThreadPoolExecutor.java:1136)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@17.0.18/ThreadPoolExecutor.java:635)
	at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:120)
"Thread-4 (ActiveMQ-scheduled-threads)":
	at jdk.internal.misc.Unsafe.park(java.base@17.0.18/Native Method)
	- parking to wait for  <0x000000052dac7a80> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
	at java.util.concurrent.locks.LockSupport.park(java.base@17.0.18/LockSupport.java:211)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(java.base@17.0.18/AbstractQueuedSynchronizer.java:715)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(java.base@17.0.18/AbstractQueuedSynchronizer.java:938)
	at java.util.concurrent.locks.ReentrantLock$Sync.lock(java.base@17.0.18/ReentrantLock.java:153)
	at java.util.concurrent.locks.ReentrantLock.lock(java.base@17.0.18/ReentrantLock.java:322)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.lockFailover(ClientSessionFactoryImpl.java:279)
	at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager.lockSessionCreation(ActiveMQClientProtocolManager.java:175)
	at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager.createSessionContext(ActiveMQClientProtocolManager.java:289)
	at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager.createSessionContext(ActiveMQClientProtocolManager.java:253)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.createSessionChannel(ClientSessionFactoryImpl.java:1473)
	- locked <0x000000052d4ec878> (a java.lang.Object)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.createSessionInternal(ClientSessionFactoryImpl.java:834)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.createSession(ClientSessionFactoryImpl.java:359)
	at org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl.connect(FederatedQueueConsumerImpl.java:136)
	- locked <0x00000005248d8888> (a org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl)
	at org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl.lambda$scheduleConnect$0(FederatedQueueConsumerImpl.java:122)
	at org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl$$Lambda$992/0x00007f5158686000.run(Unknown Source)
	at java.util.concurrent.Executors$RunnableAdapter.call(java.base@17.0.18/Executors.java:539)
	at java.util.concurrent.FutureTask.run(java.base@17.0.18/FutureTask.java:264)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(java.base@17.0.18/ScheduledThreadPoolExecutor.java:304)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@17.0.18/ThreadPoolExecutor.java:1136)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@17.0.18/ThreadPoolExecutor.java:635)
	at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:120)
"Thread-4723 (ActiveMQ-client-global-threads)":
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.interruptConnectAndCloseAllSessions(ClientSessionFactoryImpl.java:486)
	- waiting to lock <0x000000052d4ec878> (a java.lang.Object)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.cleanup(ClientSessionFactoryImpl.java:527)
	at org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumerImpl.connectionFailed(FederatedQueueConsumerImpl.java:345)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.callSessionFailureListeners(ClientSessionFactoryImpl.java:865)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.failoverOrReconnect(ClientSessionFactoryImpl.java:791)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:567)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.handleConnectionFailure(ClientSessionFactoryImpl.java:560)
	at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl.connectionException(ClientSessionFactoryImpl.java:427)
	at org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnector$Listener.lambda$connectionException$1(NettyConnector.java:1261)
	at org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnector$Listener$$Lambda$1265/0x00007f5158878d20.run(Unknown Source)
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:59)
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:32)
	at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68)
	at org.apache.activemq.artemis.utils.actors.ProcessorBase$$Lambda$532/0x00007f51583c7b50.run(Unknown Source)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@17.0.18/ThreadPoolExecutor.java:1136)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@17.0.18/ThreadPoolExecutor.java:635)
	at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:120)
{noformat}
The {{failoverOrReconnect()}} method is calling {{callSessionFailureListeners()}} **inside** the try block, meaning it is still holding {{newFailoverLock}} when the listeners are invoked.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@artemis.apache.org
For additional commands, e-mail: issues-help@artemis.apache.org