question: public void testABandCBbrokerNetwork ( ) throws Exception { bridgeBrokers ( "BrokerA" , "BrokerB" ) ; bridgeBrokers ( "BrokerC" , "BrokerB" ) ; startAllBrokers ( ) ; Destination dest = createDestination ( "TEST.FOO" , true ) ; MessageConsumer clientA = createConsumer ( "BrokerA" , dest ) ; MessageConsumer clientB = createConsumer ( "BrokerB" , dest ) ; MessageConsumer clientC = createConsumer ( "BrokerC" , dest ) ; Thread . sleep ( 2000 ) ; sendMessages ( "BrokerA" , dest , MESSAGE_COUNT ) ; sendMessages ( "BrokerB" , dest , MESSAGE_COUNT ) ; sendMessages ( "BrokerC" , dest , MESSAGE_COUNT ) ; MessageIdList msgsA = getConsumerMessages ( "BrokerA" , clientA ) ; MessageIdList msgsB = getConsumerMessages ( "BrokerB" , clientB ) ; MessageIdList msgsC = getConsumerMessages ( "BrokerC" , clientC ) ; msgsA . waitForMessagesToArrive ( MESSAGE_COUNT ) ; msgsB . waitForMessagesToArrive ( MESSAGE_COUNT * 3 ) ; msgsC . waitForMessagesToArrive ( MESSAGE_COUNT ) ; assertEquals ( MESSAGE_COUNT , msgsA . getMessageCount ( ) ) ; assertEquals ( MESSAGE_COUNT * 3 , msgsB . getMessageCount ( ) ) ; assertEquals ( MESSAGE_COUNT , msgsC . getMessageCount ( ) ) ; }
target:  BrokerA -> BrokerB <- BrokerC