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 intermittent failures

Browse Source
This commit is contained in:
Clebert Suconic 2020-04-21 13:56:48 -04:00
parent 964198494b
commit daeec3e7ab
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/federation/FederatedQueueTest.java
View File

@ -36,7 +36,9 @@ import org.apache.activemq.artemis.core.server.transformer.Transformer;
import org.apache.activemq.artemis.core.settings.impl.AddressSettings; 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.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;
/** /**
@ -45,6 +47,11 @@ import org.junit.Test;
public class FederatedQueueTest extends FederatedTestBase { public class FederatedQueueTest extends FederatedTestBase {
// I could not make this test to fail locally even after many retries
// however I have seen eventually failures on the CI
@Rule
public RetryRule retryRule = new RetryRule(1);
@Override @Override
@Before @Before
public void setUp() throws Exception { public void setUp() throws Exception {
@ -114,10 +121,10 @@ public class FederatedQueueTest extends FederatedTestBase {
Queue queue0 = session0.createQueue(queueName); Queue queue0 = session0.createQueue(queueName);
Queue queue1 = session1.createQueue(queueName); Queue queue1 = session1.createQueue(queueName);
MessageConsumer consumer0 = session0.createConsumer(queue0);
MessageConsumer consumer1 = session1.createConsumer(queue1); MessageConsumer consumer1 = session1.createConsumer(queue1);
Wait.waitFor(() -> getConsumerCount(getServer(1), queueName, 1));
MessageConsumer consumer0 = session0.createConsumer(queue0);
Wait.waitFor(() -> getConsumerCount(getServer(1), queueName, 2)); Wait.waitFor(() -> getConsumerCount(getServer(1), queueName, 2));
MessageProducer producer1 = session1.createProducer(queue1); MessageProducer producer1 = session1.createProducer(queue1);

3
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/security/LegacyLDAPSecuritySettingPluginTest2.java
View File

@ -45,7 +45,6 @@ import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.ActiveMQServers; import org.apache.activemq.artemis.core.server.ActiveMQServers;
import org.apache.activemq.artemis.core.server.impl.LegacyLDAPSecuritySettingPlugin; import org.apache.activemq.artemis.core.server.impl.LegacyLDAPSecuritySettingPlugin;
import org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager; import org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager;
import org.apache.activemq.artemis.spi.core.security.jaas.LDAPLoginModule;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.directory.server.annotations.CreateLdapServer; import org.apache.directory.server.annotations.CreateLdapServer;
import org.apache.directory.server.annotations.CreateTransport; import org.apache.directory.server.annotations.CreateTransport;
@ -159,8 +158,6 @@ public class LegacyLDAPSecuritySettingPluginTest2 extends AbstractLdapTestUnit {
@Test @Test
public void testBasicPluginAuthorization() throws Exception { public void testBasicPluginAuthorization() throws Exception {
org.jboss.logmanager.Logger.getLogger(LDAPLoginModule.class.getName()).setLevel(org.jboss.logmanager.Level.DEBUG);
org.jboss.logmanager.Logger.getLogger(LegacyLDAPSecuritySettingPlugin.class.getName()).setLevel(org.jboss.logmanager.Level.DEBUG);
server.start(); server.start();
ClientSessionFactory cf = locator.createSessionFactory(); ClientSessionFactory cf = locator.createSessionFactory();
String name = "TEST.FOO"; String name = "TEST.FOO";