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 #1391

This commit is contained in:
Clebert Suconic 2017-07-10 14:41:32 -04:00
parent 75d8a3c243 ab92306d81
commit ca9b6d4cc0
1 changed files with 4 additions and 0 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/client/MultipleProducersTest.java
View File

@ -32,6 +32,7 @@ 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.core.settings.impl.SlowConsumerPolicy; import org.apache.activemq.artemis.core.settings.impl.SlowConsumerPolicy;
import org.apache.activemq.artemis.tests.util.JMSTestBase; import org.apache.activemq.artemis.tests.util.JMSTestBase;
import org.apache.activemq.artemis.tests.util.Wait;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -141,6 +142,9 @@ public class MultipleProducersTest extends JMSTestBase {
conn.close(); conn.close();
Wait.waitFor(() -> server.locateQueue(queueOneName).getMessageCount() == 5);
Wait.waitFor(() -> server.locateQueue(queueTwoName).getMessageCount() == 5);
queueOneMsgCount = server.locateQueue(queueOneName).getMessageCount(); queueOneMsgCount = server.locateQueue(queueOneName).getMessageCount();
queueTwoMsgCount = server.locateQueue(queueTwoName).getMessageCount(); queueTwoMsgCount = server.locateQueue(queueTwoName).getMessageCount();