You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2020/06/01 19:21:52 UTC

[activemq-artemis] branch master updated: NO-JIRA Add RetryRule to FailoverClusterTest

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 0b7ecf1  NO-JIRA Add RetryRule to FailoverClusterTest
     new cee2c52  This closes #3157
0b7ecf1 is described below

commit 0b7ecf1a41a1fed54d73632f1a79caca8a24754d
Author: brusdev <br...@gmail.com>
AuthorDate: Mon Jun 1 19:45:36 2020 +0200

    NO-JIRA Add RetryRule to FailoverClusterTest
---
 .../org/apache/activemq/transport/failover/FailoverClusterTest.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java
index 1ba1d19..a86acc8 100644
--- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java
+++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTest.java
@@ -34,14 +34,19 @@ import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.artemis.core.config.Configuration;
 import org.apache.activemq.artemis.jms.server.config.impl.JMSConfigurationImpl;
 import org.apache.activemq.artemis.jms.server.embedded.EmbeddedJMS;
+import org.apache.activemq.artemis.utils.RetryRule;
 import org.apache.activemq.broker.artemiswrapper.OpenwireArtemisBaseTest;
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
+import org.junit.Rule;
 import org.junit.Test;
 
 public class FailoverClusterTest extends OpenwireArtemisBaseTest {
 
+   @Rule
+   public RetryRule retryRule = new RetryRule(2);
+
    private static final int NUMBER = 10;
    private String clientUrl;