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 <[email protected]>
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;