Author: clebert.suconic(a)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 -----------------------------------------------------