This is an automated email from the ASF dual-hosted git repository.
tabish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 3574bdbf73 NO-JIRA Fix test showing instability in CI
3574bdbf73 is described below
commit 3574bdbf7351f5a2c9285fb1be31060826b32eee
Author: Timothy Bish <[email protected]>
AuthorDate: Fri Oct 3 14:06:27 2025 -0400
NO-JIRA Fix test showing instability in CI
---
.../amqp/connect/AMQPBridgeFromAddressTest.java | 20 ++++++++++++--------
1 file changed, 12 insertions(+), 8 deletions(-)
diff --git
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeFromAddressTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeFromAddressTest.java
index 4bdcf2e2a9..e32f544370 100644
---
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeFromAddressTest.java
+++
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeFromAddressTest.java
@@ -3702,10 +3702,6 @@ class AMQPBridgeFromAddressTest extends
AmqpClientTestSupport {
containsString(server.getNodeID().toString())))
.respond();
peer.expectFlow().withLinkCredit(1000);
- peer.expectFlow().withLinkCredit(1000).withDrain(true)
- .respond()
-
.withLinkCredit(0).withDeliveryCount(1000).withDrain(true);
- peer.expectDetach().respond().afterDelay(50); // Defer the detach
response for a bit
server.addAddressInfo(new AddressInfo(SimpleString.of(getTestName()),
RoutingType.MULTICAST));
@@ -3722,6 +3718,12 @@ class AMQPBridgeFromAddressTest extends
AmqpClientTestSupport {
connection.start();
consumer.receiveNoWait();
+
+ peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
+ peer.expectFlow().withLinkCredit(1000).withDrain(true)
+ .respond()
+
.withLinkCredit(0).withDeliveryCount(1000).withDrain(true);
+ peer.expectDetach().respond().afterDelay(50); // Defer the detach
response for a bit
}
peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
@@ -3740,10 +3742,6 @@ class AMQPBridgeFromAddressTest extends
AmqpClientTestSupport {
containsString(server.getNodeID().toString())))
.respond();
peer.expectFlow().withLinkCredit(1000);
- peer.expectFlow().withLinkCredit(1000).withDrain(true)
- .respond()
-
.withLinkCredit(0).withDeliveryCount(1000).withDrain(true);
- peer.expectDetach().respond();
// Create demand on the address which creates a bridge receiver again
quickly which
// can trigger a new receiver before the previous one was fully
closed with a Detach
@@ -3756,6 +3754,12 @@ class AMQPBridgeFromAddressTest extends
AmqpClientTestSupport {
connection.start();
consumer.receiveNoWait();
+
+ peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
+ peer.expectFlow().withLinkCredit(1000).withDrain(true)
+ .respond()
+
.withLinkCredit(0).withDeliveryCount(1000).withDrain(true);
+ peer.expectDetach().respond();
}
peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
