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 Fix intermittent test failure

This commit is contained in:
Timothy Bish 2024-09-06 11:15:57 -04:00
parent daba842984
commit acc415126f
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2476,7 +2476,6 @@ public class AMQPFederationQueuePolicyTest extends AmqpClientTestSupport {
.withOfferedCapabilities(FEDERATION_QUEUE_RECEIVER.toString());
// Should get a flow but if the link goes away quick enough the broker won't get to this before detaching.
target.expectFlow().withLinkCredit(1000).optional();
target.expectDetach().respond();
// Simulate another broker connecting as a federation instance that will create demand on
// queue "test::test" and should generate demand to the server the broker connected to
@ -2508,15 +2507,19 @@ public class AMQPFederationQueuePolicyTest extends AmqpClientTestSupport {
client.remoteFlow().withLinkCredit(10).now();
client.waitForScriptToComplete(5, TimeUnit.SECONDS);
// Now force close the federation link in an unexpected way which should cause the target to
// react and close the federation connection and trigger a rebuild of state, federation links
// should normally never be deleted by user management but if it is the state needs to be
// rebuilt in order for proper demand tracking.
target.waitForScriptToComplete(5, TimeUnit.SECONDS);
target.expectDetach().respond();
client.expectDetach();
client.expectClose().respond();
client.remoteDetach().withErrorCondition("amqp:resource-deleted", "Resource deleted").later(30);
client.waitForScriptToComplete(5, TimeUnit.SECONDS);
}
target.waitForScriptToComplete(5, TimeUnit.SECONDS);
target.expectClose();
target.remoteClose().now();
target.waitForScriptToComplete(5, TimeUnit.SECONDS);
target.close();
}