[hornetq-commits] JBoss hornetq SVN: r11069 - in branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl: wireformat and 1 other directory.
do-not-reply at jboss.org
do-not-reply at jboss.org
Fri Jul 29 13:25:36 EDT 2011
Author: borges
Date: 2011-07-29 13:25:36 -0400 (Fri, 29 Jul 2011)
New Revision: 11069
Modified:
branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java
branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java
branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionSendMessage.java
Log:
Make 'type' private.
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java 2011-07-29 17:24:59 UTC (rev 11068)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java 2011-07-29 17:25:36 UTC (rev 11069)
@@ -38,7 +38,7 @@
protected long channelID;
- protected final byte type;
+ private final byte type;
protected int size = -1;
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java 2011-07-29 17:24:59 UTC (rev 11068)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java 2011-07-29 17:25:36 UTC (rev 11069)
@@ -87,7 +87,7 @@
int len = size - DataConstants.SIZE_INT;
buffer.setInt(0, len);
- buffer.setByte(DataConstants.SIZE_INT, type);
+ buffer.setByte(DataConstants.SIZE_INT, getType());
buffer.setLong(DataConstants.SIZE_INT + DataConstants.SIZE_BYTE, channelID);
// Position reader for reading by Netty
Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionSendMessage.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionSendMessage.java 2011-07-29 17:24:59 UTC (rev 11068)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/SessionSendMessage.java 2011-07-29 17:25:36 UTC (rev 11069)
@@ -82,7 +82,7 @@
int len = size - DataConstants.SIZE_INT;
buffer.setInt(0, len);
- buffer.setByte(DataConstants.SIZE_INT, type);
+ buffer.setByte(DataConstants.SIZE_INT, getType());
buffer.setLong(DataConstants.SIZE_INT + DataConstants.SIZE_BYTE, channelID);
// Position reader for reading by Netty
More information about the hornetq-commits
mailing list