This closes #389
This commit is contained in:
commit
b815212ec6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client
|
@ -146,6 +146,7 @@ public class ReceiveTest extends ActiveMQTestBase {
|
||||||
cp.send(sendSession.createMessage(false));
|
cp.send(sendSession.createMessage(false));
|
||||||
cp.send(sendSession.createMessage(false));
|
cp.send(sendSession.createMessage(false));
|
||||||
cp.send(sendSession.createMessage(false));
|
cp.send(sendSession.createMessage(false));
|
||||||
|
sendSession.commit();
|
||||||
|
|
||||||
Assert.assertNotNull(cc2.receive(5000));
|
Assert.assertNotNull(cc2.receive(5000));
|
||||||
Assert.assertNotNull(cc.receive(5000));
|
Assert.assertNotNull(cc.receive(5000));
|
||||||
|
|
Loading…
Reference in New Issue