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 Fix AMQP federation pull consumer test failures 

Fix intermittent test failures in pull consumer test by asserting that there
are the expected number of message on the queue before running the JMS consume
cycle to consume credit and trigger federation credit to flow.
This commit is contained in:
Timothy Bish 2024-03-01 11:08:44 -05:00
parent cffc72fd51
commit f9f5ed373f
1 changed files with 5 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/amqp/connect/AMQPFederationQueuePolicyTest.java
View File

@ -103,6 +103,7 @@ import org.apache.activemq.artemis.protocol.amqp.federation.FederationReceiveFro
import org.apache.activemq.artemis.protocol.amqp.proton.AmqpSupport;
import org.apache.activemq.artemis.tests.integration.amqp.AmqpClientTestSupport;
import org.apache.activemq.artemis.tests.util.CFUtil;
import org.apache.activemq.artemis.utils.Wait;
import org.apache.qpid.proton.amqp.transport.AmqpError;
import org.apache.qpid.proton.amqp.transport.LinkError;
import org.apache.qpid.protonj2.test.driver.ProtonTestClient;
@ -2718,6 +2719,8 @@ public class AMQPFederationQueuePolicyTest extends AmqpClientTestSupport {
peer.expectFlow().withLinkCredit(10);
peer.start();
final SimpleString queueName = SimpleString.toSimpleString("test");
final URI remoteURI = peer.getServerURI();
logger.info("Test started, peer listening on: {}", remoteURI);
@ -2782,6 +2785,8 @@ public class AMQPFederationQueuePolicyTest extends AmqpClientTestSupport {
.now();
}
Wait.assertTrue(() -> server.queueQuery(queueName).getMessageCount() == DEFAULT_PULL_CREDIT_BATCH_SIZE, 10_000);
// Consume all the newly received message from the remote except one
// which should leave the queue with a pending message so no credit
// should be offered.