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 random test failures if flow is omitted 

If the remote detach arrives fast enough it can suppress the flow from
being sent by the broker so the test should mark that as an optional frame.
This commit is contained in:
Timothy Bish 2024-05-28 10:44:00 -04:00 committed by Robbie Gemmell
parent c47713454c
commit f4d9cfdca8
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3155,7 +3155,7 @@ public class AMQPFederationAddressPolicyTest extends AmqpClientTestSupport {
peer.remoteDetach().withClosed(true) peer.remoteDetach().withClosed(true)
.withErrorCondition(AmqpError.NOT_FOUND.toString(), "Address not found") .withErrorCondition(AmqpError.NOT_FOUND.toString(), "Address not found")
.queue(); .queue();
peer.expectFlow(); peer.expectFlow().optional();
peer.expectDetach(); peer.expectDetach();
server.createQueue(new QueueConfiguration("test").setRoutingType(RoutingType.MULTICAST) server.createQueue(new QueueConfiguration("test").setRoutingType(RoutingType.MULTICAST)

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

@ -3394,7 +3394,7 @@ public class AMQPFederationQueuePolicyTest extends AmqpClientTestSupport {
peer.remoteDetach().withClosed(true) peer.remoteDetach().withClosed(true)
.withErrorCondition(AmqpError.NOT_FOUND.toString(), "Queue not found") .withErrorCondition(AmqpError.NOT_FOUND.toString(), "Queue not found")
.queue(); .queue();
peer.expectFlow(); peer.expectFlow().optional();
peer.expectDetach(); peer.expectDetach();
final ConnectionFactory factory = CFUtil.createConnectionFactory("AMQP", "tcp://localhost:" + AMQP_PORT); final ConnectionFactory factory = CFUtil.createConnectionFactory("AMQP", "tcp://localhost:" + AMQP_PORT);