[QPID-3911] Consumer.close() and session.rollback() deadlocks

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.15
• Fix Version/s: 0.16
• Component/s: JMS AMQP 0-x
• Labels: java qpidclient

Environment

0.16(beta/RC1) Java Client and Java Broker

• Assignee: Robbie Gemmell
• Reporter: Praveen Murugesan
• Created: 22/Mar/12 22:58
• Updated: 14/Mar/17 20:07
• Resolved: 06/Apr/12 10:59

Description

Found one Java-level deadlock:
=============================
"Dispatcher-Channel-0":
waiting to lock monitor 0x0000000001e65ec8 (object
0x00000007c180bd58, a java.lang.Object),
which is held by "main"
"main":
waiting to lock monitor 0x0000000001cffbc8 (object
0x00000007c2e10c08, a java.lang.Object),
which is held by "Dispatcher-Channel-0"

Java stack information for the threads listed above:
===================================================
"Dispatcher-Channel-0":
at
org.apache.qpid.client.AMQConnection.exceptionReceived(AMQConnection.java:1255)

• waiting to lock <0x00000007c180bd58> (a java.lang.Object)
  at
  org.apache.qpid.client.AMQSession_0_10.setCurrentException(AMQSession_0_10.java:1057)
  at
  org.apache.qpid.client.AMQSession_0_10.sync(AMQSession_0_10.java:1034)
  at
  org.apache.qpid.client.AMQSession_0_10.sendSuspendChannel(AMQSession_0_10.java:851)
  at
  org.apache.qpid.client.AMQSession.suspendChannel(AMQSession.java:3075)
• locked <0x00000007c2c3d330> (a java.lang.Object)
  at org.apache.qpid.client.AMQSession.rollback(AMQSession.java:1854)
• locked <0x00000007c2c3d330> (a java.lang.Object)
  at
  QpidConsumerCloseRollbackDeadlock$QpidMqHandler.onMessage(QpidConsumerCloseRollbackDeadlock.java:208)
  at
  org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:745)
  at
  org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:141)
  at
  org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:719)
  at
  org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:186)
  at
  org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:54)
  at
  org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3467)
  at
  org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3406)
• locked <0x00000007c2c3d350> (a java.lang.Object)
• locked <0x00000007c2e10c08> (a java.lang.Object)
  at
  org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.java:3180)
  at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3173)
  at
  org.apache.qpid.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54)
  at
  org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3329)
  at java.lang.Thread.run(Thread.java:636)
  "main":
  at
  org.apache.qpid.client.AMQSession$Dispatcher.rejectPending(AMQSession.java:3211)
• waiting to lock <0x00000007c2e10c08> (a java.lang.Object)
  at
  org.apache.qpid.client.AMQSession.confirmConsumerCancelled(AMQSession.java:903)
  at
  org.apache.qpid.client.BasicMessageConsumer_0_10.sendCancel(BasicMessageConsumer_0_10.java:170)
  at
  org.apache.qpid.client.BasicMessageConsumer.close(BasicMessageConsumer.java:593)
• locked <0x00000007c180bd58> (a java.lang.Object)
  at
  org.apache.qpid.client.BasicMessageConsumer.close(BasicMessageConsumer.java:555)
  at
  QpidConsumerCloseRollbackDeadlock.main(QpidConsumerCloseRollbackDeadlock.java:77)

Found 1 deadlock.