question: public void testBAandBCbrokerNetworkWithSelectorsSendFirst ( ) throws Exception { bridgeBrokers ( "BrokerB" , "BrokerA" , true , 1 , false ) ; bridgeBrokers ( "BrokerB" , "BrokerC" , true , 1 , false ) ; startAllBrokers ( ) ; waitForBridgeFormation ( ) ; Destination dest = createDestination ( "TEST.FOO" , false ) ; HashMap < String , Object > props = new HashMap < > ( ) ; props . put ( "broker" , "BROKER_A" ) ; sendMessages ( "BrokerB" , dest , MESSAGE_COUNT , props ) ; props . clear ( ) ; props . put ( "broker" , "BROKER_C" ) ; sendMessages ( "BrokerB" , dest , MESSAGE_COUNT , props ) ; MessageConsumer clientA = createConsumer ( "BrokerA" , dest , "broker = 'BROKER_A'" ) ; MessageConsumer clientC = createConsumer ( "BrokerC" , dest , "broker = 'BROKER_C'" ) ; Thread . sleep ( 2000 ) ; MessageIdList msgsA = getConsumerMessages ( "BrokerA" , clientA ) ; MessageIdList msgsC = getConsumerMessages ( "BrokerC" , clientC ) ; assertEquals ( MESSAGE_COUNT , msgsA . getMessageCount ( ) ) ; assertEquals ( MESSAGE_COUNT , msgsC . getMessageCount ( ) ) ; }
target:  BrokerA <- BrokerB -> BrokerC