[hornetq-commits] JBoss hornetq SVN: r10756 - branches/Branch_2_2_EAP_export_tool/tests/src/org/hornetq/tests/integration/persistence.
Author: jicken
Date: 2011-05-31 17:51:56 -0400 (Tue, 31 May 2011)
New Revision: 10756
Modified:
branches/Branch_2_2_EAP_export_tool/tests/src/org/hornetq/tests/integration/persistence/ExportDataTest.java
Log:
added a check for the size of the message body
Modified:
branches/Branch_2_2_EAP_export_tool/tests/src/org/hornetq/tests/integration/persistence/ExportDataTest.java
===================================================================
---
branches/Branch_2_2_EAP_export_tool/tests/src/org/hornetq/tests/integration/persistence/ExportDataTest.java 2011-05-31
21:39:47 UTC (rev 10755)
+++
branches/Branch_2_2_EAP_export_tool/tests/src/org/hornetq/tests/integration/persistence/ExportDataTest.java 2011-05-31
21:51:56 UTC (rev 10756)
@@ -39,6 +39,7 @@
public class ExportDataTest extends ServiceTestBase {
protected static HornetQJMSConnectionFactory myCf;
+ private static final int MSG_SIZE = 1024;
public void testExportImport() throws Exception {
@@ -65,7 +66,7 @@
ClientMessage msg = session.createMessage(true);
msg.putStringProperty("prop", "TST1");
msg.putIntProperty("count", i);
- for (int b = 0; b < 1024; b++)
+ for (int b = 0; b < MSG_SIZE; b++)
{
msg.getBodyBuffer().writeByte(getSamplebyte(b));
}
@@ -117,6 +118,7 @@
{
ClientMessage msg = cons.receive(1000);
assertNotNull(msg);
+ assertEquals(MSG_SIZE, msg.getBodyBuffer().readableBytes());
for (int b = 0; b < msg.getBodyBuffer().readableBytes(); b++) {
assertEquals(getSamplebyte(b), msg.getBodyBuffer().readByte());
}