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

ARTEMIS-3372 - ensure test verification happens after expected failover event such that expected message is not tracked as a duplicate

This commit is contained in:
gtully 2021-07-09 12:41:17 +01:00
parent 000f83dbc2
commit 3961fd1cf2
1 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/management/OpenWireDeleteQueueTest.java
View File

@ -24,11 +24,13 @@ import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
import java.io.IOException;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.api.core.TransportConfiguration;
@ -39,6 +41,7 @@ import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
import org.apache.activemq.artemis.tests.integration.management.ManagementControlHelper;
import org.apache.activemq.artemis.tests.integration.openwire.OpenWireTestBase;
import org.apache.activemq.artemis.tests.util.Wait;
import org.apache.activemq.transport.TransportListener;
import org.junit.Before;
import org.junit.Test;
@ -109,6 +112,29 @@ public class OpenWireDeleteQueueTest extends OpenWireTestBase {
return bindings.contains(queueName1);
}));
// expect a failover event
final CountDownLatch failoverStart = new CountDownLatch(1);
final CountDownLatch failoverEnd = new CountDownLatch(1);
((ActiveMQConnection)connection).addTransportListener(new TransportListener() {
@Override
public void onCommand(Object command) {
}
@Override
public void onException(IOException error) {
}
@Override
public void transportInterupted() {
failoverStart.countDown();
}
@Override
public void transportResumed() {
failoverEnd.countDown();
}
});
// the test op, will force a disconnect, failover will kick in..
serverControl.destroyQueue(queueName1.toString(), true);
@ -118,7 +144,10 @@ public class OpenWireDeleteQueueTest extends OpenWireTestBase {
}));
// expect a failover event
assertTrue(failoverStart.await(5, TimeUnit.SECONDS));
assertTrue(failoverEnd.await(5, TimeUnit.SECONDS));
// failover complete, no chance of this message getting resent and detected as duplicate
producer.send(session.createTextMessage("two"));
assertTrue(two.await(5, TimeUnit.SECONDS));