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

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