activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject [2/2] activemq git commit: remove timing depdendency
Date Thu, 16 Apr 2015 14:31:30 GMT
remove timing depdendency


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/7dc522d4
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/7dc522d4
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/7dc522d4

Branch: refs/heads/master
Commit: 7dc522d4c30736191aa256f07be051dc5e5f5e94
Parents: 4441001
Author: gtully <gary.tully@gmail.com>
Authored: Mon Apr 13 16:46:08 2015 +0100
Committer: gtully <gary.tully@gmail.com>
Committed: Thu Apr 16 15:25:58 2015 +0100

----------------------------------------------------------------------
 .../apache/activemq/network/DemandForwardingBridgeTest.java   | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/7dc522d4/activemq-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java
index 9794337..9c23781 100755
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java
@@ -75,6 +75,13 @@ public class DemandForwardingBridgeTest extends NetworkTestSupport {
         connection1.send(consumerInfo1.createRemoveCommand());
 
         final DestinationStatistics destinationStatistics = broker.getDestination(destination).getDestinationStatistics();
+
+        Wait.waitFor(new Wait.Condition() {
+            @Override
+            public boolean isSatisified() throws Exception {
+                return 1 == destinationStatistics.getDispatched().getCount();
+            }
+        });
         assertEquals("broker dest stat dispatched", 1, destinationStatistics.getDispatched().getCount());
         assertEquals("broker dest stat dequeues", 0, destinationStatistics.getDequeues().getCount());
         assertEquals("broker dest stat forwards", 0, destinationStatistics.getForwards().getCount());


Mime
View raw message