[activemq-artemis] branch master updated: NO-JIRA Fixing intermittent failure (Wait condition)

[clebertsuconic]

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 863f029  NO-JIRA Fixing intermittent failure (Wait condition)
     new c8f357c  This closes #3116
863f029 is described below

commit 863f0298d54ac88926e2eb1295e9cf0f4a33d48e
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Mon May 4 18:48:46 2020 -0400

    NO-JIRA Fixing intermittent failure (Wait condition)
---
 .../activemq/artemis/tests/integration/plugin/MetricsPluginTest.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/plugin/MetricsPluginTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/plugin/MetricsPluginTest.java
index 26fbd2b..5ea1486 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/plugin/MetricsPluginTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/plugin/MetricsPluginTest.java
@@ -37,6 +37,7 @@ import 
org.apache.activemq.artemis.api.core.client.ClientSession;
 import org.apache.activemq.artemis.api.core.client.ClientSessionFactory;
 import org.apache.activemq.artemis.api.core.client.ServerLocator;
 import org.apache.activemq.artemis.core.server.ActiveMQServer;
+import org.apache.activemq.artemis.core.server.Queue;
 import 
org.apache.activemq.artemis.core.server.metrics.plugins.SimpleMetricsPlugin;
 import org.apache.activemq.artemis.core.settings.impl.AddressFullMessagePolicy;
 import org.apache.activemq.artemis.tests.util.Wait;
@@ -159,6 +160,9 @@ public class MetricsPluginTest extends ActiveMQTestBase {
       producer.send(message);
       producer.close();
 
+      Queue queue = server.locateQueue(queueName);
+      Wait.assertEquals(1, queue::getMessageCount);
+
       Map<Meter.Id, Double> metrics = getMetrics();
 
       checkMetric(metrics, "artemis.message.count", "queue", queueName, 1.0);