Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #2649

This commit is contained in:
Clebert Suconic 2019-04-30 13:34:26 -04:00
parent 9143177fe7 c0300c318c
commit 39475c68e9
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/GlobalPagingTest.java
View File

@ -46,6 +46,7 @@ import org.apache.activemq.artemis.core.server.Queue;
import org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl; import org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl;
import org.apache.activemq.artemis.core.settings.impl.AddressFullMessagePolicy; import org.apache.activemq.artemis.core.settings.impl.AddressFullMessagePolicy;
import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
import org.apache.activemq.artemis.junit.Wait;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Ignore; import org.junit.Ignore;
@ -334,7 +335,8 @@ public class GlobalPagingTest extends PagingTest {
final MessageReference reference = MessageReference.Factory.createReference(session.createMessage(false), queue); final MessageReference reference = MessageReference.Factory.createReference(session.createMessage(false), queue);
//it will cause QueueImpl::directDeliver -> false //it will cause QueueImpl::directDeliver -> false
queue.addHead(reference, false); queue.addHead(reference, false);
Assert.assertSame(reference, queue.removeReferenceWithID(reference.getMessageID())); Wait.assertFalse(queue::isDirectDeliver);
Wait.assertTrue(() -> queue.removeReferenceWithID(reference.getMessageID()) != null);
ClientMessage message = session.createMessage(false); ClientMessage message = session.createMessage(false);
message.putStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME, replyQueue); message.putStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME, replyQueue);
ManagementHelper.putAttribute(message, "queue." + address.toString(), "messageCount"); ManagementHelper.putAttribute(message, "queue." + address.toString(), "messageCount");