question: public void testDuplexStaticRemoteBrokerHasNoConsumer ( ) throws Exception { boolean dynamicOnly = true ; int networkTTL = 2 ; boolean conduit = true ; bridgeBrokers ( "BrokerA" , "BrokerB" , dynamicOnly , networkTTL , conduit ) ; bridgeBrokers ( "BrokerB" , "BrokerA" , dynamicOnly , networkTTL , conduit ) ; startAllBrokers ( ) ; Destination dest = createDestination ( "TEST.FOO" , false ) ; MessageConsumer clientA = createConsumer ( "BrokerA" , dest ) ; Thread . sleep ( 2 * 1000 ) ; int messageCount = 2000 ; sendMessages ( "BrokerA" , dest , messageCount ) ; MessageIdList msgsA = getConsumerMessages ( "BrokerA" , clientA ) ; msgsA . waitForMessagesToArrive ( messageCount ) ; assertEquals ( messageCount , msgsA . getMessageCount ( ) ) ; }
target:  BrokerA -> BrokerB && BrokerB -> BrokerA