public void testVirtualDestinationsDinamicallyIncludedBehavior3() throws Exception {
  final String topic="global.test";
  final String vq="Consumer.foo." + topic;
  startAllBrokers();
  final int msgs1=1001;
  final int msgs2=1456;
  Destination tDest=createDestination(topic,true);
  Destination vqDest=createDestination(vq,false);
  MessageConsumer clientB1t=createConsumer("BrokerA",tDest);
  MessageConsumer clientB2t=createConsumer("BrokerB",tDest);
  MessageConsumer clientB1vq=createConsumer("BrokerA",vqDest);
  Thread.sleep(2 * 1000);
  sendMessages("BrokerA",tDest,msgs1);
  sendMessages("BrokerB",tDest,msgs2);
  Thread.sleep(5000);
  MessageIdList msgsB1t=getConsumerMessages("BrokerA",clientB1t);
  msgsB1t.waitForMessagesToArrive(msgs1 + msgs2);
  assertEquals(msgs1 + msgs2,msgsB1t.getMessageCount());
  MessageIdList msgsB2t=getConsumerMessages("BrokerB",clientB2t);
  msgsB2t.waitForMessagesToArrive(msgs1 + msgs2);
  assertEquals(msgs1 + msgs2,msgsB2t.getMessageCount());
  MessageIdList msgsB1vq=getConsumerMessages("BrokerA",clientB1vq);
  msgsB1vq.waitForMessagesToArrive(msgs1 + msgs2);
  assertEquals(msgs1 + msgs2,msgsB1vq.getMessageCount());
  assertEquals(0,getQueueSize("BrokerA",(ActiveMQDestination)vqDest));
  assertEquals(0,getQueueSize("BrokerB",(ActiveMQDestination)vqDest));
  destroyAllBrokers();
}

public void testVirtualDestinationsDinamicallyIncludedBehavior3 ( ) throws Exception { final String topic = "global.test" ; final String vq = "Consumer.foo." + topic ; startAllBrokers ( ) ; final int msgs1 = 1001 ; final int msgs2 = 1456 ; Destination tDest = createDestination ( topic , true ) ; Destination vqDest = createDestination ( vq , false ) ; MessageConsumer clientB1t = createConsumer ( "BrokerA" , tDest ) ; MessageConsumer clientB2t = createConsumer ( "BrokerB" , tDest ) ; MessageConsumer clientB1vq = createConsumer ( "BrokerA" , vqDest ) ; Thread . sleep ( 2 * 1000 ) ; sendMessages ( "BrokerA" , tDest , msgs1 ) ; sendMessages ( "BrokerB" , tDest , msgs2 ) ; Thread . sleep ( 5000 ) ; MessageIdList msgsB1t = getConsumerMessages ( "BrokerA" , clientB1t ) ; msgsB1t . waitForMessagesToArrive ( msgs1 + msgs2 ) ; assertEquals ( msgs1 + msgs2 , msgsB1t . getMessageCount ( ) ) ; MessageIdList msgsB2t = getConsumerMessages ( "BrokerB" , clientB2t ) ; msgsB2t . waitForMessagesToArrive ( msgs1 + msgs2 ) ; assertEquals ( msgs1 + msgs2 , msgsB2t . getMessageCount ( ) ) ; MessageIdList msgsB1vq = getConsumerMessages ( "BrokerA" , clientB1vq ) ; msgsB1vq . waitForMessagesToArrive ( msgs1 + msgs2 ) ; assertEquals ( msgs1 + msgs2 , msgsB1vq . getMessageCount ( ) ) ; assertEquals ( 0 , getQueueSize ( "BrokerA" , ( ActiveMQDestination ) vqDest ) ) ; assertEquals ( 0 , getQueueSize ( "BrokerB" , ( ActiveMQDestination ) vqDest ) ) ; destroyAllBrokers ( ) ; }
brokera - > brokerb & & brokerb - > brokera
