[hornetq-commits] JBoss hornetq SVN: r8077 - branches/Replication_Clebert/src/main/org/hornetq/core/remoting/impl/wireformat.
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 -----------------------------------------------------