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

This commit is contained in:
Clebert Suconic 2016-02-08 16:59:14 -05:00
parent aefdeb23a5 82eca32ba4
commit fffd81f80c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java
View File

@ -3552,7 +3552,7 @@ public class PagingTest extends ActiveMQTestBase {
for (int i = 0; i < NUMBER_MESSAGES_BEFORE_PAGING; i++) { for (int i = 0; i < NUMBER_MESSAGES_BEFORE_PAGING; i++) {
ClientMessage msg = session.createMessage(true); ClientMessage msg = session.createMessage(true);
msg.getBodyBuffer().writeBytes(new byte[512]); msg.getBodyBuffer().writeBytes(new byte[896]);
producerA.send(msg); producerA.send(msg);
producerB.send(msg); producerB.send(msg);
@ -3565,7 +3565,7 @@ public class PagingTest extends ActiveMQTestBase {
for (int i = 0; i < NUMBER_MESSAGES_BEFORE_PAGING; i++) { for (int i = 0; i < NUMBER_MESSAGES_BEFORE_PAGING; i++) {
ClientMessage msg = session.createMessage(true); ClientMessage msg = session.createMessage(true);
msg.getBodyBuffer().writeBytes(new byte[512]); msg.getBodyBuffer().writeBytes(new byte[896]);
producerA.send(msg); producerA.send(msg);
producerB.send(msg); producerB.send(msg);
@ -3578,7 +3578,7 @@ public class PagingTest extends ActiveMQTestBase {
for (int i = NUMBER_MESSAGES_BEFORE_PAGING * 2; i < NUMBER_OF_MESSAGES; i++) { for (int i = NUMBER_MESSAGES_BEFORE_PAGING * 2; i < NUMBER_OF_MESSAGES; i++) {
ClientMessage msg = session.createMessage(true); ClientMessage msg = session.createMessage(true);
msg.getBodyBuffer().writeBytes(new byte[512]); msg.getBodyBuffer().writeBytes(new byte[896]);
producerA.send(msg); producerA.send(msg);
producerB.send(msg); producerB.send(msg);