You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Timothy Bish (JIRA)" <ji...@apache.org> on 2017/01/05 16:45:58 UTC
[jira] [Resolved] (QPIDJMS-242) Creation of consumer, producer or
session hangs when connection is in a process of re-establishing by
failover
[ https://issues.apache.org/jira/browse/QPIDJMS-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timothy Bish resolved QPIDJMS-242.
----------------------------------
Resolution: Fixed
Fix Version/s: 0.20.0
> Creation of consumer, producer or session hangs when connection is in a process of re-establishing by failover
> --------------------------------------------------------------------------------------------------------------
>
> Key: QPIDJMS-242
> URL: https://issues.apache.org/jira/browse/QPIDJMS-242
> Project: Qpid JMS
> Issue Type: Bug
> Components: qpid-jms-client
> Affects Versions: 0.11.1, 0.20.0
> Environment: Qpid Broker 7.0.0-SNAPSHOT
> Reporter: Alex Rudyy
> Assignee: Timothy Bish
> Fix For: 0.20.0
>
> Attachments: ConsumerCreationHangsOnFailover.java, broker-log.snippet.txt, thread-dump.txt
>
>
> The creation of consumer (Session#createConsumer) hangs if invoked when underlying connection is being re-established by failover process. Even when failover successfully restores the connectivity, the invoked method createConsumer does not return. I see the following in the stack trace:
> {noformat}
> "main" prio=10 tid=0x00007f2524009800 nid=0x3d5d waiting on condition [0x00007f252b0e4000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000007ad360b30> (a java.util.concurrent.CountDownLatch$Sync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:834)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:994)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1303)
> at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:236)
> at org.apache.qpid.jms.provider.ProviderFuture.sync(ProviderFuture.java:97)
> at org.apache.qpid.jms.JmsConnection.createResource(JmsConnection.java:601)
> at org.apache.qpid.jms.JmsConnection.createResource(JmsConnection.java:590)
> at org.apache.qpid.jms.JmsMessageConsumer.<init>(JmsMessageConsumer.java:114)
> at org.apache.qpid.jms.JmsMessageConsumer.<init>(JmsMessageConsumer.java:72)
> at org.apache.qpid.jms.JmsSession.createConsumer(JmsSession.java:387)
> at org.apache.qpid.jms.JmsSession.createConsumer(JmsSession.java:375)
> at org.apache.qpid.jms.JmsSession.createConsumer(JmsSession.java:367)
> at org.apache.qpid.jms.example.Test2.main(Test2.java:65)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:606)
> at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
> {noformat}
> The consumer is created successfully on broker side. Broker even sends the messages through.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org