[jboss-cvs] JBoss Messaging SVN: r5053 - trunk/src/main/org/jboss/messaging/core/paging/impl.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Tue Sep 30 13:22:49 EDT 2008
Author: clebert.suconic at jboss.com
Date: 2008-09-30 13:22:49 -0400 (Tue, 30 Sep 2008)
New Revision: 5053
Modified:
trunk/src/main/org/jboss/messaging/core/paging/impl/PageMessageImpl.java
Log:
Removing ID from PagingEncoding since now is part of ServerMessageImpl.encode()
Modified: trunk/src/main/org/jboss/messaging/core/paging/impl/PageMessageImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/paging/impl/PageMessageImpl.java 2008-09-30 17:21:53 UTC (rev 5052)
+++ trunk/src/main/org/jboss/messaging/core/paging/impl/PageMessageImpl.java 2008-09-30 17:22:49 UTC (rev 5053)
@@ -26,6 +26,7 @@
import org.jboss.messaging.core.remoting.spi.MessagingBuffer;
import org.jboss.messaging.core.server.ServerMessage;
import org.jboss.messaging.core.server.impl.ServerMessageImpl;
+import org.jboss.messaging.util.DataConstants;
/**
*
@@ -82,21 +83,19 @@
public void decode(final MessagingBuffer buffer)
{
transactionID = buffer.getLong();
- message.setMessageID(buffer.getLong());
message.decode(buffer);
}
public void encode(final MessagingBuffer buffer)
{
buffer.putLong(transactionID);
- buffer.putLong(message.getMessageID());
message.encode(buffer);
}
public int getEncodeSize()
{
- return 8 * 2 + message.getEncodeSize();
+ return DataConstants.SIZE_LONG + message.getEncodeSize();
}
// Package protected ---------------------------------------------
More information about the jboss-cvs-commits
mailing list