svn commit: r939682 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java

[gtully]

Author: gtully
Date: Fri Apr 30 14:16:33 2010
New Revision: 939682

URL: http://svn.apache.org/viewvc?rev=939682&view=rev
Log:
add setDecreaseNetworkConsumerPriority and send another message to try and find 
problem, still good

Modified:
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java?rev=939682&r1=939681&r2=939682&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java
 Fri Apr 30 14:16:33 2010
@@ -28,6 +28,7 @@ import org.apache.activemq.broker.region
 import org.apache.activemq.broker.region.virtual.VirtualDestination;
 import org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor;
 import org.apache.activemq.broker.region.virtual.VirtualTopic;
+import org.apache.activemq.network.NetworkConnector;
 import org.apache.activemq.store.kahadb.KahaDBStore;
 import org.apache.activemq.util.MessageIdList;
 import org.apache.commons.logging.Log;
@@ -100,25 +101,26 @@ public class ThreeBrokerVirtualTopicNetw
         
         Thread.sleep(2000);
 
-        sendMessages("BrokerA", dest, 1);
+        sendMessages("BrokerA", dest, 2);
 
         msgsA = getConsumerMessages("BrokerA", clientA);
 
-        msgsA.waitForMessagesToArrive(1);
-        msgsB.waitForMessagesToArrive(2);
-        msgsC.waitForMessagesToArrive(2);
+        msgsA.waitForMessagesToArrive(2);
+        msgsB.waitForMessagesToArrive(3);
+        msgsC.waitForMessagesToArrive(3);
 
         // ensure we don't get any more messages
         Thread.sleep(2000);
         
-        assertEquals(1, msgsA.getMessageCount());
-        assertEquals(2, msgsB.getMessageCount());
-        assertEquals(2, msgsC.getMessageCount());        
+        assertEquals(2, msgsA.getMessageCount());
+        assertEquals(3, msgsB.getMessageCount());
+        assertEquals(3, msgsC.getMessageCount());        
     }
     
 
     private void bridgeAndConfigureBrokers(String local, String remote, 
boolean dynamicOnly, int networkTTL, boolean conduitSubs) throws Exception {
-        bridgeBrokers(local, remote, dynamicOnly, networkTTL, conduitSubs);
+        NetworkConnector bridge = bridgeBrokers(local, remote, dynamicOnly, 
networkTTL, conduitSubs);
+        bridge.setDecreaseNetworkConsumerPriority(true);
     }
 
     public void setUp() throws Exception {