You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2010/04/30 16:16:33 UTC
svn commit: r939682 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerVirtualTopicNetworkTest.java
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 {