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 e58287a3a4 ARTEMIS-5173 Small tweak on DiscoveryTest
e58287a3a4 is described below

commit e58287a3a4479c1a38b4d97b7f927b7f0bf4980d
Author: Clebert Suconic <[email protected]>
AuthorDate: Wed Dec 4 12:19:11 2024 -0500

    ARTEMIS-5173 Small tweak on DiscoveryTest
---
 .../activemq/artemis/tests/integration/discovery/DiscoveryTest.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
index 9dc4347e96..bb0a4786b5 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/discovery/DiscoveryTest.java
@@ -929,7 +929,9 @@ public class DiscoveryTest extends DiscoveryBaseTest {
 
       dg.stop();
 
-      assertEquals(2, 
notifListener.count(CoreNotificationType.DISCOVERY_GROUP_STARTED, 
CoreNotificationType.DISCOVERY_GROUP_STOPPED));
+      Wait.assertEquals(2, () -> 
notifListener.count(CoreNotificationType.DISCOVERY_GROUP_STARTED, 
CoreNotificationType.DISCOVERY_GROUP_STOPPED), 5000, 100);
+      notif = 
notifListener.findAny(CoreNotificationType.DISCOVERY_GROUP_STOPPED);
+      assertEquals(CoreNotificationType.DISCOVERY_GROUP_STOPPED, 
notif.getType());
       assertEquals(dg.getName(), 
notif.getProperties().getSimpleStringProperty(SimpleString.of("name")).toString());
    }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact


Reply via email to