[hornetq-commits] JBoss hornetq SVN: r9879 - branches/Branch_Large_Message_Compression/tests/src/org/hornetq/tests/integration/client.
Author: gaohoward
Date: 2010-11-12 00:23:35 -0500 (Fri, 12 Nov 2010)
New Revision: 9879
Modified:
branches/Branch_Large_Message_Compression/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java
Log:
test
Modified:
branches/Branch_Large_Message_Compression/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java
===================================================================
---
branches/Branch_Large_Message_Compression/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java 2010-11-12
04:51:39 UTC (rev 9878)
+++
branches/Branch_Large_Message_Compression/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java 2010-11-12
05:23:35 UTC (rev 9879)
@@ -2697,6 +2697,7 @@
server.start();
ClientSessionFactory sf = createFactory(isNetty());
+ sf.setCompressLargeMessages(true);
session = sf.createSession(false, false, false);
@@ -2714,21 +2715,22 @@
ClientConsumer consumer = session.createConsumer(LargeMessageTest.ADDRESS);
ClientMessage msg1 = consumer.receive(1000);
+ Assert.assertNotNull(msg1);
+
+ for (int i = 0 ; i < messageSize; i++)
+ {
+ //System.out.print(msg1.getBodyBuffer().readByte() + " ");
+ //if (i % 100 == 0) System.out.println();
+ byte b = msg1.getBodyBuffer().readByte();
+ //System.out.println("Byte read: " + (char)b + " i " +
i);
+ assertEquals("position = " + i, getSamplebyte(i), b);
+ }
+
msg1.acknowledge();
session.commit();
- Assert.assertNotNull(msg1);
consumer.close();
- try
- {
- msg1.getBodyBuffer().readByte();
- Assert.fail("Exception was expected");
- }
- catch (Throwable ignored)
- {
- }
-
session.close();
validateNoFilesOnLargeDir();