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

This commit is contained in:
jbertram 2016-02-08 10:40:50 -06:00
parent b6ca733c85 efffe9c263
commit 650fb58fda
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/AddressControlTest.java
View File

@ -206,7 +206,7 @@ public class AddressControlTest extends ManagementTestBase {
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]);
producer.send(msg); producer.send(msg);
} }
session.commit(); session.commit();
@ -215,21 +215,21 @@ public class AddressControlTest extends ManagementTestBase {
Assert.assertEquals(0, addressControl.getNumberOfPages()); Assert.assertEquals(0, addressControl.getNumberOfPages());
ClientMessage msg = session.createMessage(true); ClientMessage msg = session.createMessage(true);
msg.getBodyBuffer().writeBytes(new byte[512]); msg.getBodyBuffer().writeBytes(new byte[896]);
producer.send(msg); producer.send(msg);
session.commit(); session.commit();
Assert.assertEquals(1, addressControl.getNumberOfPages()); Assert.assertEquals(1, addressControl.getNumberOfPages());
msg = session.createMessage(true); msg = session.createMessage(true);
msg.getBodyBuffer().writeBytes(new byte[512]); msg.getBodyBuffer().writeBytes(new byte[896]);
producer.send(msg); producer.send(msg);
session.commit(); session.commit();
Assert.assertEquals(1, addressControl.getNumberOfPages()); Assert.assertEquals(1, addressControl.getNumberOfPages());
msg = session.createMessage(true); msg = session.createMessage(true);
msg.getBodyBuffer().writeBytes(new byte[512]); msg.getBodyBuffer().writeBytes(new byte[896]);
producer.send(msg); producer.send(msg);
session.commit(); session.commit();