Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-03-01 06:49:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA retry-tests

Browse Source
This commit is contained in:
Clebert Suconic 2020-04-20 14:40:37 -04:00
parent 974609d206
commit ba3d638149
3 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/reattach/MultiThreadReattachSupportTestBase.java
View File

@ -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.core.remoting.impl.invm.InVMConnector;
import org.apache.activemq.artemis.tests.integration.IntegrationTestLogger; import org.apache.activemq.artemis.tests.integration.IntegrationTestLogger;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.activemq.artemis.utils.RetryRule;
import org.junit.After; import org.junit.After;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Rule;
public abstract class MultiThreadReattachSupportTestBase extends ActiveMQTestBase { public abstract class MultiThreadReattachSupportTestBase extends ActiveMQTestBase {
@Rule
public RetryRule retryRule = new RetryRule(2);
private final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; private final IntegrationTestLogger log = IntegrationTestLogger.LOGGER;
private Timer timer; private Timer timer;

5
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RetroactiveAddressTest.java
View File

@ -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.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.activemq.artemis.tests.util.Wait; import org.apache.activemq.artemis.tests.util.Wait;
import org.apache.activemq.artemis.utils.RetryRule;
import org.junit.Before; import org.junit.Before;
import org.junit.Rule;
import org.junit.Test; import org.junit.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
import org.junit.runners.Parameterized; import org.junit.runners.Parameterized;
@ -55,6 +57,9 @@ import org.junit.runners.Parameterized;
@RunWith(value = Parameterized.class) @RunWith(value = Parameterized.class)
public class RetroactiveAddressTest extends ActiveMQTestBase { public class RetroactiveAddressTest extends ActiveMQTestBase {
@Rule
public RetryRule retryRule = new RetryRule(2);
protected ActiveMQServer server; protected ActiveMQServer server;
protected ClientSession session; protected ClientSession session;

5
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ssl/CoreClientOverOneWaySSLKerb5Test.java
View File

@ -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.spi.core.security.ActiveMQSecurityManager;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.activemq.artemis.utils.RandomUtil; import org.apache.activemq.artemis.utils.RandomUtil;
import org.apache.activemq.artemis.utils.RetryRule;
import org.apache.hadoop.minikdc.MiniKdc; import org.apache.hadoop.minikdc.MiniKdc;
import org.junit.After; import org.junit.After;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Rule;
import org.junit.Test; import org.junit.Test;
import java.io.File; import java.io.File;
@ -54,6 +56,9 @@ import java.util.Set;
public class CoreClientOverOneWaySSLKerb5Test extends ActiveMQTestBase { public class CoreClientOverOneWaySSLKerb5Test extends ActiveMQTestBase {
@Rule
public RetryRule retryRule = new RetryRule(2);
public static final SimpleString QUEUE = new SimpleString("QueueOverKrb5SSL"); public static final SimpleString QUEUE = new SimpleString("QueueOverKrb5SSL");
public static final String CLIENT_PRINCIPAL = "client"; public static final String CLIENT_PRINCIPAL = "client";
public static final String SNI_HOST = "sni.host"; public static final String SNI_HOST = "sni.host";