Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Fixing intermittent failure

This commit is contained in:
Clebert Suconic 2020-04-23 22:28:13 -04:00
parent bddb67cd9a
commit c883a73746
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/federation/FederatedAddressTest.java
View File

@ -37,7 +37,9 @@ import org.apache.activemq.artemis.core.server.impl.AddressInfo;
import org.apache.activemq.artemis.core.server.transformer.Transformer; import org.apache.activemq.artemis.core.server.transformer.Transformer;
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,8 @@ import org.junit.Test;
*/ */
public class FederatedAddressTest extends FederatedTestBase { public class FederatedAddressTest extends FederatedTestBase {
@Rule
public RetryRule retryRule = new RetryRule(2);
@Override @Override
@Before @Before
@ -298,7 +302,7 @@ public class FederatedAddressTest extends FederatedTestBase {
1000, 100)); 1000, 100));
final QueueBinding remoteQueueBinding = (QueueBinding) getServer(1).getPostOffice().getBindingsForAddress(SimpleString.toSimpleString(address)) final QueueBinding remoteQueueBinding = (QueueBinding) getServer(1).getPostOffice().getBindingsForAddress(SimpleString.toSimpleString(address))
.getBindings().iterator().next(); .getBindings().iterator().next();
assertEquals(1, remoteQueueBinding.getQueue().getConsumerCount()); Wait.assertEquals(1, () -> remoteQueueBinding.getQueue().getConsumerCount());
producer1.send(session1.createTextMessage("hello")); producer1.send(session1.createTextMessage("hello"));
assertNotNull(consumer0.receive(1000)); assertNotNull(consumer0.receive(1000));