[jboss-cvs] JBoss Messaging SVN: r5120 - in branches/Branch_Chunk_Clebert: src/main/org/jboss/messaging/core/message/impl and 2 other directories.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-10-16 11:57:55 -0400 (Thu, 16 Oct 2008)
New Revision: 5120

Added:
   branches/Branch_Chunk_Clebert/jbm-large-messages/
Modified:
   branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/message/impl/MessageImpl.java
   branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendMessage.java
   branches/Branch_Chunk_Clebert/tests/jms-tests/src/org/jboss/test/messaging/jms/JMSTest.java
Log:


Modified: branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/message/impl/MessageImpl.java
===================================================================
--- branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/message/impl/MessageImpl.java	2008-10-16 00:06:24 UTC (rev 5119)
+++ branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/message/impl/MessageImpl.java	2008-10-16 15:57:55 UTC (rev 5120)
@@ -225,6 +225,7 @@
       byte[] bytes = new byte[len];
       buffer.getBytes(bytes);
       body = new ByteBufferWrapper(ByteBuffer.wrap(bytes));
+      body.position(body.limit());
    }
 
    public long getMessageID()

Modified: branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendMessage.java
===================================================================
--- branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendMessage.java	2008-10-16 00:06:24 UTC (rev 5119)
+++ branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendMessage.java	2008-10-16 15:57:55 UTC (rev 5120)
@@ -140,6 +140,8 @@
       
       serverMessage.decode(buffer);
       
+      serverMessage.getBody().flip();
+      
       requiresResponse = buffer.getBoolean();
    }
 

Modified: branches/Branch_Chunk_Clebert/tests/jms-tests/src/org/jboss/test/messaging/jms/JMSTest.java
===================================================================
--- branches/Branch_Chunk_Clebert/tests/jms-tests/src/org/jboss/test/messaging/jms/JMSTest.java	2008-10-16 00:06:24 UTC (rev 5119)
+++ branches/Branch_Chunk_Clebert/tests/jms-tests/src/org/jboss/test/messaging/jms/JMSTest.java	2008-10-16 15:57:55 UTC (rev 5120)
@@ -95,6 +95,8 @@
 	      conn.start();
 
 	      TextMessage rm = (TextMessage)cons.receive();
+	      
+	      assertNotNull(rm);
 
 	      assertEquals("message one", rm.getText());
       }