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 796ee0534a ARTEMIS-5173 Trying to improve reliability on
FederatedAddressTest
796ee0534a is described below
commit 796ee0534aedf16c1ee2fce191a15b4ad41b5a77
Author: Clebert Suconic <[email protected]>
AuthorDate: Wed Dec 11 12:39:42 2024 -0500
ARTEMIS-5173 Trying to improve reliability on FederatedAddressTest
---
.../artemis/tests/integration/federation/FederatedAddressTest.java | 3 +--
1 file changed, 1 insertion(+), 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 6261e3e667..ac051201f8 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
@@ -373,8 +373,7 @@ public class FederatedAddressTest extends FederatedTestBase
{
.setRoutingType(ComponentConfigurationRoutingType.ANYCAST));
}
- assertTrue(Wait.waitFor(() ->
getServer(1).getPostOffice().getBindingsForAddress(SimpleString.of(address)).getBindings().size()
== 1,
- 1000, 100));
+ Wait.assertEquals(1L, () ->
getServer(1).getPostOffice().getBindingsForAddress(SimpleString.of(address)).getBindings().size(),
10_000, 100);
final QueueBinding remoteQueueBinding = (QueueBinding)
getServer(1).getPostOffice().getBindingsForAddress(SimpleString.of(address))
.getBindings().iterator().next();
Wait.assertEquals(1, () ->
remoteQueueBinding.getQueue().getConsumerCount());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
