[hornetq-commits] JBoss hornetq SVN: r10756 - branches/Branch_2_2_EAP_export_tool/tests/src/org/hornetq/tests/integration/persistence.

[do-not-reply at jboss.org]

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());
             }