public void testABandBCbrokerNetwork() throws Exception {
  bridgeBrokers("BrokerA","BrokerB");
  bridgeBrokers("BrokerB","BrokerC");
  startAllBrokers();
  waitForBridgeFormation();
  Destination dest=createDestination("TEST.FOO",false);
  MessageConsumer clientC=createConsumer("BrokerC",dest);
  sendMessages("BrokerA",dest,MESSAGE_COUNT);
  Thread.sleep(1000);
  MessageIdList msgsC=getConsumerMessages("BrokerC",clientC);
  assertEquals(0,msgsC.getMessageCount());
}

public void testABandBCbrokerNetwork ( ) throws Exception { bridgeBrokers ( "BrokerA" , "BrokerB" ) ; bridgeBrokers ( "BrokerB" , "BrokerC" ) ; startAllBrokers ( ) ; waitForBridgeFormation ( ) ; Destination dest = createDestination ( "TEST.FOO" , false ) ; MessageConsumer clientC = createConsumer ( "BrokerC" , dest ) ; sendMessages ( "BrokerA" , dest , MESSAGE_COUNT ) ; Thread . sleep ( 1000 ) ; MessageIdList msgsC = getConsumerMessages ( "BrokerC" , clientC ) ; assertEquals ( 0 , msgsC . getMessageCount ( ) ) ; }
brokera - > brokerb - > brokerc
