This is an automated email from the ASF dual-hosted git repository.
clebertsuconic 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 a630fe0882 ARTEMIS-5530 Fixing intermittent failure on FederationTest
a630fe0882 is described below
commit a630fe08829c1d942bb02a07a77a6c14e71d294b
Author: Clebert Suconic <[email protected]>
AuthorDate: Thu Aug 14 21:39:19 2025 -0400
ARTEMIS-5530 Fixing intermittent failure on FederationTest
---
.../artemis/tests/integration/federation/FederatedAddressTest.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/federation/FederatedAddressTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/federation/FederatedAddressTest.java
index 6318f7bb0b..828b82a0a9 100644
---
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/federation/FederatedAddressTest.java
+++
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/federation/FederatedAddressTest.java
@@ -684,6 +684,9 @@ public class FederatedAddressTest extends FederatedTestBase
{
MessageProducer producer = session0.createProducer(topic0);
+ Wait.assertEquals(2, () ->
getServer(0).getPostOffice().getBindingsForAddress(SimpleString.of(address)).getBindings().size(),
5000, 100);
+ Wait.assertEquals(2, () ->
getServer(1).getPostOffice().getBindingsForAddress(SimpleString.of(address)).getBindings().size(),
5000, 100);
+
sendAndConsume(producer, session0, DATA_REGULAR, "regular",
consumer0, consumer1);
sendAndConsume(producer, session0, DATA_COMPRESSED_LARGE,
"compressedLarge", consumer0, consumer1);
sendAndConsume(producer, session0, DATA_COMPRESSED_REGULAR,
"compressedRegular", consumer0, consumer1);
@@ -701,8 +704,8 @@ public class FederatedAddressTest extends FederatedTestBase
{
message.setStringProperty("identification", identification);
producer.send(message);
}
- TextMessage message0 = (TextMessage) consumer0.receive(1000);
- TextMessage message1 = (TextMessage) consumer1.receive(1000);
+ TextMessage message0 = (TextMessage) consumer0.receive(10_000);
+ TextMessage message1 = (TextMessage) consumer1.receive(10_000);
assertNotNull(message0);
assertNotNull(message1);
assertEquals(data, message0.getText());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
