NO-JIRA Fixing NotificationTest

apache · Apr 2, 2020 · b0cfbe0 · b0cfbe0
1 parent aefd730
commit b0cfbe0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../test/java/org/apache/activemq/artemis/tests/integration/management/NotificationTest.java b/.../test/java/org/apache/activemq/artemis/tests/integration/management/NotificationTest.java
@@ -87,7 +87,7 @@ public void testBINDING_ADDED() throws Exception {
       Assert.assertEquals(BINDING_ADDED.toString(), notifications[1].getObjectProperty(ManagementHelper.HDR_NOTIFICATION_TYPE).toString());
       Assert.assertEquals(queue.toString(), notifications[1].getObjectProperty(ManagementHelper.HDR_ROUTING_NAME).toString());
       Assert.assertEquals(address.toString(), notifications[1].getObjectProperty(ManagementHelper.HDR_ADDRESS).toString());
-      Assert.assertTrue(notifications[1].getTimestamp() > start);
+      Assert.assertTrue(notifications[1].getTimestamp() >= start);
       Assert.assertTrue((long) notifications[1].getObjectProperty(ManagementHelper.HDR_NOTIFICATION_TIMESTAMP) >= start);
       Assert.assertEquals(notifications[1].getTimestamp(), (long) notifications[1].getObjectProperty(ManagementHelper.HDR_NOTIFICATION_TIMESTAMP));
 
@@ -473,7 +473,7 @@ public void setUp() throws Exception {
    private static void flush(final ClientConsumer notifConsumer) throws ActiveMQException {
       ClientMessage message = null;
       do {
-         message = notifConsumer.receive(500);
+         message = notifConsumer.receiveImmediate();
       }
       while (message != null);
    }