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
commit ba3d638149830b7482ff893d71645a7937a507a3 Author: Clebert Suconic <[email protected]> AuthorDate: Mon Apr 20 14:40:37 2020 -0400 NO-JIRA retry-tests --- .../cluster/reattach/MultiThreadReattachSupportTestBase.java | 5 +++++ .../artemis/tests/integration/server/RetroactiveAddressTest.java | 5 +++++ .../tests/integration/ssl/CoreClientOverOneWaySSLKerb5Test.java | 5 +++++ 3 files changed, 15 insertions(+) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/reattach/MultiThreadReattachSupportTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/reattach/MultiThreadReattachSupportTestBase.java index 095b943..22b969a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/reattach/MultiThreadReattachSupportTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/reattach/MultiThreadReattachSupportTestBase.java @@ -31,12 +31,17 @@ import org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImp import org.apache.activemq.artemis.core.remoting.impl.invm.InVMConnector; import org.apache.activemq.artemis.tests.integration.IntegrationTestLogger; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; +import org.apache.activemq.artemis.utils.RetryRule; import org.junit.After; import org.junit.Assert; import org.junit.Before; +import org.junit.Rule; public abstract class MultiThreadReattachSupportTestBase extends ActiveMQTestBase { + @Rule + public RetryRule retryRule = new RetryRule(2); + private final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; private Timer timer; diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RetroactiveAddressTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RetroactiveAddressTest.java index b499a12..21a8dc3 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RetroactiveAddressTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RetroactiveAddressTest.java @@ -47,7 +47,9 @@ import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.Wait; +import org.apache.activemq.artemis.utils.RetryRule; import org.junit.Before; +import org.junit.Rule; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; @@ -55,6 +57,9 @@ import org.junit.runners.Parameterized; @RunWith(value = Parameterized.class) public class RetroactiveAddressTest extends ActiveMQTestBase { + @Rule + public RetryRule retryRule = new RetryRule(2); + protected ActiveMQServer server; protected ClientSession session; diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverOneWaySSLKerb5Test.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverOneWaySSLKerb5Test.java index 377d238..88251ec 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverOneWaySSLKerb5Test.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverOneWaySSLKerb5Test.java @@ -38,10 +38,12 @@ import org.apache.activemq.artemis.core.server.ActiveMQServers; import org.apache.activemq.artemis.spi.core.security.ActiveMQSecurityManager; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.utils.RandomUtil; +import org.apache.activemq.artemis.utils.RetryRule; import org.apache.hadoop.minikdc.MiniKdc; import org.junit.After; import org.junit.Assert; import org.junit.Before; +import org.junit.Rule; import org.junit.Test; import java.io.File; @@ -54,6 +56,9 @@ import java.util.Set; public class CoreClientOverOneWaySSLKerb5Test extends ActiveMQTestBase { + @Rule + public RetryRule retryRule = new RetryRule(2); + public static final SimpleString QUEUE = new SimpleString("QueueOverKrb5SSL"); public static final String CLIENT_PRINCIPAL = "client"; public static final String SNI_HOST = "sni.host";
