[activemq-artemis] branch master updated: NO-JIRA Fixing GeneralInteropTest stability

[cl...@apache.org]

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 974a800  NO-JIRA Fixing GeneralInteropTest stability
     new 04572f9  This closes #3027
974a800 is described below

commit 974a80002a5b5bb603c92a1111ae31b480af6115
Author: brusdev <br...@gmail.com>
AuthorDate: Tue Mar 17 20:26:40 2020 +0100

    NO-JIRA Fixing GeneralInteropTest stability
---
 .../tests/integration/openwire/interop/GeneralInteropTest.java       | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/interop/GeneralInteropTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/interop/GeneralInteropTest.java
index 6372110..66d7247 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/interop/GeneralInteropTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/interop/GeneralInteropTest.java
@@ -235,7 +235,8 @@ public class GeneralInteropTest extends BasicOpenWireTest {
             }
          }
 
-         Wait.assertEquals(0, queueControl::getDeliveringCount);
+         Wait.assertEquals(1L, () -> queueControl.getMessagesAcknowledged(), 3000, 100);
+         Wait.assertEquals(prefetchSize, () -> queueControl.getDeliveringCount(), 3000, 100);
 
          message = consumer.receive(5000);
          assertNotNull(message);
@@ -243,7 +244,7 @@ public class GeneralInteropTest extends BasicOpenWireTest {
          assertEquals(text + 1, ((TextMessage)message).getText());
          message.acknowledge();
 
-         Wait.assertEquals(1L, () -> queueControl.getMessagesAcknowledged(), 3000, 100);
+         Wait.assertEquals(2L, () -> queueControl.getMessagesAcknowledged(), 3000, 100);
          Wait.assertEquals(prefetchSize, () -> queueControl.getDeliveringCount(), 30000, 100);
       } finally {
          connection.close();