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