[activemq-artemis] branch master updated: NO-JIRA Fixing GlobalPagingTest

[cl...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 9872128  NO-JIRA Fixing GlobalPagingTest
9872128 is described below

commit 9872128a1fc7dd1721ef1cbcbd0221564bc523d5
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Thu May 2 12:24:19 2019 -0400

    NO-JIRA Fixing GlobalPagingTest
---
 .../activemq/artemis/tests/integration/paging/GlobalPagingTest.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/GlobalPagingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/GlobalPagingTest.java
index 856d767..b128598 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/GlobalPagingTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/GlobalPagingTest.java
@@ -330,13 +330,15 @@ public class GlobalPagingTest extends PagingTest {
             try (ClientProducer requestProducer = session.createProducer(managementAddress)) {
                final SimpleString replyQueue = new SimpleString(managementAddress + "." + UUID.randomUUID().toString());
                session.createTemporaryQueue(replyQueue, ActiveMQDefaultConfiguration.getDefaultRoutingType(), replyQueue);
+               int id = 1000;
                try (ClientConsumer consumer = session.createConsumer(replyQueue)) {
                   final Queue queue = server.locateQueue(replyQueue);
                   final MessageReference reference = MessageReference.Factory.createReference(session.createMessage(false), queue);
+                  reference.getMessage().setMessageID(id++);
                   //it will cause QueueImpl::directDeliver -> false
                   queue.addHead(reference, false);
                   Wait.assertFalse(queue::isDirectDeliver);
-                  Wait.assertTrue(() -> queue.removeReferenceWithID(reference.getMessageID()) != null);
+                  queue.removeReferenceWithID(reference.getMessageID());
                   ClientMessage message = session.createMessage(false);
                   message.putStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME, replyQueue);
                   ManagementHelper.putAttribute(message, "queue." + address.toString(), "messageCount");