[activemq-artemis] branch master updated: NO-JIRA OpenWire test retry

[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 c63aa9f  NO-JIRA OpenWire test retry
c63aa9f is described below

commit c63aa9f4815ff92a4b82bca60eb2e4300a4cdfc8
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Wed Dec 23 11:14:29 2020 -0500

    NO-JIRA OpenWire test retry
---
 .../integration/openwire/cluster/TemporaryQueueClusterTest.java  | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
index b1afdd6..c8134eb 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/cluster/TemporaryQueueClusterTest.java
@@ -19,8 +19,10 @@ package org.apache.activemq.artemis.tests.integration.openwire.cluster;
 import org.apache.activemq.ActiveMQConnection;
 import org.apache.activemq.artemis.api.core.RoutingType;
 import org.apache.activemq.artemis.api.core.SimpleString;
+import org.apache.activemq.artemis.utils.RetryRule;
 import org.apache.activemq.artemis.utils.Wait;
 import org.junit.Before;
+import org.junit.Rule;
 import org.junit.Test;
 
 import javax.jms.Connection;
@@ -31,6 +33,13 @@ import javax.jms.Session;
 import javax.jms.TextMessage;
 
 public class TemporaryQueueClusterTest extends OpenWireJMSClusteredTestBase {
+
+   /** There is a possible race on the openwire client receiving updates from
+    *  the Advisor Consumer.
+    *  Nothing we can do here beyond retry the test. */
+   @Rule
+   public RetryRule retryRule = new RetryRule(3);
+
    @Override
    public boolean isFileStorage() {
       return false;