activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [2/3] activemq-artemis git commit: ARTEMIS-1011 Small adjustment on test
Date Thu, 09 Mar 2017 22:27:23 GMT
ARTEMIS-1011 Small adjustment on test


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

Branch: refs/heads/master
Commit: 9818206bd3aa893864eedf06d19d0c2d5c355a9c
Parents: 19ebbfb
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Thu Mar 9 17:20:05 2017 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Thu Mar 9 17:21:16 2017 -0500

----------------------------------------------------------------------
 .../tests/integration/client/SlowConsumerTest.java        | 10 +++-------
 1 file changed, 3 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9818206b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
index 4f47ac1..00417ae 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
@@ -269,13 +269,9 @@ public class SlowConsumerTest extends ActiveMQTestBase {
       ClientConsumer consumer = addClientConsumer(session.createConsumer(QUEUE));
       session.start();
 
-      Wait.waitFor(new Wait.Condition() {
-         @Override
-         public boolean isSatisfied() throws Exception {
-            forceGC();
-            return queue.getConsumerCount() == 0;
-         }
-      }, 3000, 100);
+      Wait.waitFor(consumer::isClosed, 3000, 100);
+
+      Assert.assertTrue(consumer.isClosed());
 
       try {
          consumer.receive(500);


Mime
View raw message