[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