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

ARTEMIS-4665 Add additional state checks to fix test failures in CI 

Tests need to ensure federation links are up before sending to and address
or the sent message can get discarded before the federation consumer is there
to receive it.
This commit is contained in:
Timothy Bish 2024-02-29 15:22:10 -05:00
parent c7f536c8b8
commit cffc72fd51
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPFederationServerToServerTest.java
View File

@ -161,6 +161,10 @@ public class AMQPFederationServerToServerTest extends AmqpClientTestSupport {
Wait.assertTrue(() -> server.addressQuery(SimpleString.toSimpleString("test")).isExists());
Wait.assertTrue(() -> remoteServer.addressQuery(SimpleString.toSimpleString("test")).isExists());
// Captures state of JMS consumers and federation consumers attached on each node
Wait.assertTrue(() -> server.bindingQuery(SimpleString.toSimpleString("test"), false).getQueueNames().size() >= 1);
Wait.assertTrue(() -> remoteServer.bindingQuery(SimpleString.toSimpleString("test"), false).getQueueNames().size() >= 1);
final MessageProducer producerR = sessionR.createProducer(topic);
final TextMessage message = sessionR.createTextMessage("Hello World");
@ -240,6 +244,10 @@ public class AMQPFederationServerToServerTest extends AmqpClientTestSupport {
// Demand on local address should trigger receiver on remote.
Wait.assertTrue(() -> remoteServer.addressQuery(SimpleString.toSimpleString("source")).isExists());
// Captures state of JMS consumers and federation consumers attached on each node
Wait.assertTrue(() -> server.bindingQuery(SimpleString.toSimpleString("target"), false).getQueueNames().size() >= 1);
Wait.assertTrue(() -> remoteServer.bindingQuery(SimpleString.toSimpleString("source"), false).getQueueNames().size() >= 1);
final MessageProducer producerR = sessionR.createProducer(source);
final TextMessage message = sessionR.createTextMessage("Hello World");
@ -377,6 +385,10 @@ public class AMQPFederationServerToServerTest extends AmqpClientTestSupport {
Wait.assertTrue(() -> server.addressQuery(SimpleString.toSimpleString("test")).isExists());
Wait.assertTrue(() -> remoteServer.addressQuery(SimpleString.toSimpleString("test")).isExists());
// Captures state of JMS consumers and federation consumers attached on each node
Wait.assertTrue(() -> server.bindingQuery(SimpleString.toSimpleString("test"), false).getQueueNames().size() >= 1);
Wait.assertTrue(() -> remoteServer.bindingQuery(SimpleString.toSimpleString("test"), false).getQueueNames().size() >= 1);
final MessageProducer producerL = sessionL.createProducer(topic);
final TextMessage message = sessionL.createTextMessage("Hello World");
@ -526,6 +538,10 @@ public class AMQPFederationServerToServerTest extends AmqpClientTestSupport {
// Demand on local address should trigger receiver on remote.
Wait.assertTrue(() -> server.addressQuery(SimpleString.toSimpleString("source")).isExists());
// Captures state of JMS consumers and federation consumers attached on each node
Wait.assertTrue(() -> server.bindingQuery(SimpleString.toSimpleString("source"), false).getQueueNames().size() >= 1);
Wait.assertTrue(() -> remoteServer.bindingQuery(SimpleString.toSimpleString("target"), false).getQueueNames().size() >= 1);
final MessageProducer producerL = sessionL.createProducer(source);
final TextMessage message = sessionL.createTextMessage("Hello World");
@ -610,6 +626,10 @@ public class AMQPFederationServerToServerTest extends AmqpClientTestSupport {
Wait.assertTrue(() -> server.addressQuery(SimpleString.toSimpleString("test")).isExists());
Wait.assertTrue(() -> remoteServer.addressQuery(SimpleString.toSimpleString("test")).isExists());
// Captures state of JMS consumers and federation consumers attached on each node
Wait.assertTrue(() -> server.bindingQuery(SimpleString.toSimpleString("test"), false).getQueueNames().size() >= 1);
Wait.assertTrue(() -> remoteServer.bindingQuery(SimpleString.toSimpleString("test"), false).getQueueNames().size() >= 1);
final MessageProducer producerR = sessionR.createProducer(topic);
final BytesMessage message = sessionR.createBytesMessage();
final byte[] bodyBytes = new byte[(int)(MIN_LARGE_MESSAGE_SIZE * 1.5)];