activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r939682 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java
Date Fri, 30 Apr 2010 14:16:33 GMT
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 {



Mime
View raw message