Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-1759

DemandForwardingBridgeSupport Hung On CountDownLatch Awaiting BrokerInfo Packet

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Blocker Blocker
    • JBoss A-MQ 6.3.x
    • 6.1.1
    • broker
    • None

      After establishing a connection with a remote broker, the local broker awaits BrokerInfo packets via the FutureBrokerInfo.get() method and its CountDownLatch. The problem is that the latch is never decremented down to 0 and thus the bridge is never fully established. Here's a thread dump snippet from the local broker:

      "triggerStartAsyncNetworkBridgeCreation: remoteBroker=ssl://CHPBRP01/xxx.xx.xx.xx:xxxx, localBroker= vm://DRPBRP0111281#144" daemon prio=8 tid=0x6000000005d31800 nid=39643 lwp_id=4731599 waiting on condition [0x9fffffffa5300000]
         java.lang.Thread.State: TIMED_WAITING (parking)
      	at sun.misc.Unsafe.park(Native Method)
      	- parking to wait for  <0x9ffffffd649b00a0> (a java.util.concurrent.CountDownLatch$Sync)
      	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
      	at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1033)
      	at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1326)
      	at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:282)
      	at org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo.get(DemandForwardingBridgeSupport.java:1592)
      	at org.apache.activemq.network.DemandForwardingBridgeSupport.collectBrokerInfos(DemandForwardingBridgeSupport.java:319)
      	at org.apache.activemq.network.DemandForwardingBridgeSupport.access$400(DemandForwardingBridgeSupport.java:76)
      	at org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:302)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      	at java.lang.Thread.run(Thread.java:745)
      

        1. BrokerNetworkReconnectProblem.tgz
          11 kB
        2. JUnit-NoReconnect.log
          65 kB
        3. JUnit-NoReconnect2.log
          80 kB
        4. karaf.out
          215 kB
        5. NetworkReconnectSslNioTest.java
          5 kB

            gtully@redhat.com Gary Tully
            Argo_Integration Travis North (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            7 Start watching this issue

              Created:
              Updated:
              Resolved: