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

ARTEMIS-1274 MultipleProducersTest.wrongQueue fails

This commit is contained in:
Erich Duda 2017-07-03 15:36:28 +02:00 committed by Clebert Suconic
parent 75d8a3c243
commit ab92306d81
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.SlowConsumerPolicy;
import org.apache.activemq.artemis.tests.util.JMSTestBase;
import org.apache.activemq.artemis.tests.util.Wait;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
@ -141,6 +142,9 @@ public class MultipleProducersTest extends JMSTestBase {
conn.close();
Wait.waitFor(() -> server.locateQueue(queueOneName).getMessageCount() == 5);
Wait.waitFor(() -> server.locateQueue(queueTwoName).getMessageCount() == 5);
queueOneMsgCount = server.locateQueue(queueOneName).getMessageCount();
queueTwoMsgCount = server.locateQueue(queueTwoName).getMessageCount();