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());
}

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 ( ) ) ; }
brokera < - brokerb - > brokerc
