[hornetq-commits] JBoss hornetq SVN: r8077 - branches/Replication_Clebert/src/main/org/hornetq/core/remoting/impl/wireformat.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-10-09 16:24:02 -0400 (Fri, 09 Oct 2009)
New Revision: 8077

Modified:
   branches/Replication_Clebert/src/main/org/hornetq/core/remoting/impl/wireformat/ReplicationPageWriteMessage.java
Log:
tweak

Modified: branches/Replication_Clebert/src/main/org/hornetq/core/remoting/impl/wireformat/ReplicationPageWriteMessage.java
===================================================================
--- branches/Replication_Clebert/src/main/org/hornetq/core/remoting/impl/wireformat/ReplicationPageWriteMessage.java	2009-10-09 13:36:27 UTC (rev 8076)
+++ branches/Replication_Clebert/src/main/org/hornetq/core/remoting/impl/wireformat/ReplicationPageWriteMessage.java	2009-10-09 20:24:02 UTC (rev 8077)
@@ -53,12 +53,11 @@
    }
 
    // Public --------------------------------------------------------
-   
+
+   @Override
    public int getRequiredBufferSize()
    {
-      return BASIC_PACKET_SIZE + 
-             DataConstants.SIZE_INT +
-             pagedMessage.getEncodeSize();
+      return BASIC_PACKET_SIZE + DataConstants.SIZE_INT + pagedMessage.getEncodeSize();
 
    }
 
@@ -72,7 +71,7 @@
    @Override
    public void decodeBody(final HornetQBuffer buffer)
    {
-      this.pageNumber = buffer.readInt();
+      pageNumber = buffer.readInt();
       pagedMessage = new PagedMessageImpl();
       pagedMessage.decode(buffer);
    }
@@ -92,10 +91,7 @@
    {
       return pagedMessage;
    }
-   
-   
 
-
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------