question: 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 ( ) ; }
target:  BrokerA -> BrokerB && BrokerB -> BrokerA