activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [activemq-artemis] branch master updated: NO-JIRA fix race condition in QueueQueryTest
Date Mon, 04 Feb 2019 22:48:56 GMT
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new b711901  NO-JIRA fix race condition in QueueQueryTest
     new 91a1ea8  This closes #2538
b711901 is described below

commit b711901a4a6acc2929d85a03974781b85fbcb408
Author: Justin Bertram <jbertram@apache.org>
AuthorDate: Mon Feb 4 16:01:37 2019 -0600

    NO-JIRA fix race condition in QueueQueryTest
    
    My previous commit to fix this was amended which nullified the fix.
---
 .../activemq/artemis/tests/integration/server/QueueQueryTest.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/QueueQueryTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/QueueQueryTest.java
index 1d21f73..3771119 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/QueueQueryTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/QueueQueryTest.java
@@ -161,14 +161,14 @@ public class QueueQueryTest extends ActiveMQTestBase {
          QueueQueryResult queueQueryResult = server.queueQuery(fqqn);
          assertEquals(queueName, queueQueryResult.getName());
          assertEquals(addressName, queueQueryResult.getAddress());
-         Wait.assertEquals(1, server.queueQuery(fqqn)::getMessageCount);
+         Wait.assertEquals(1, () -> server.queueQuery(fqqn).getMessageCount());
          queueQueryResult = server.queueQuery(queueName);
          assertEquals(queueName, queueQueryResult.getName());
          assertEquals(addressName, queueQueryResult.getAddress());
          assertEquals(1, queueQueryResult.getMessageCount());
          c.createProducer().send(c.createQueue(addressName.toString()), c.createMessage());
-         Wait.assertEquals(2, server.queueQuery(fqqn)::getMessageCount);
-         Wait.assertEquals(2, server.queueQuery(queueName)::getMessageCount);
+         Wait.assertEquals(2, () -> server.queueQuery(fqqn).getMessageCount());
+         Wait.assertEquals(2, () -> server.queueQuery(queueName).getMessageCount());
       }
    }
 


Mime
View raw message