[hornetq-commits] JBoss hornetq SVN: r11140 - in branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core: protocol/core/impl/wireformat and 1 other directories.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-08-05 10:59:02 -0400 (Fri, 05 Aug 2011)
New Revision: 11140

Modified:
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java
   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/ReplicationStartSyncMessage.java
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java
Log:
HORNETQ-720 Rename Packet type code to something that makes more sense

Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java	2011-08-05 14:58:22 UTC (rev 11139)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java	2011-08-05 14:59:02 UTC (rev 11140)
@@ -533,7 +533,7 @@
             packet = new HaBackupRegistrationMessage();
             break;
          }
-         case PacketImpl.REPLICATION_FILE_ID:
+         case PacketImpl.REPLICATION_START_SYNC:
          {
             packet = new ReplicationStartSyncMessage();
             break;

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-08-05 14:58:22 UTC (rev 11139)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java	2011-08-05 14:59:02 UTC (rev 11140)
@@ -194,9 +194,10 @@
 
    public static final byte SUBSCRIBE_TOPOLOGY = 112;
 
+   /** XXX HORNETQ-720 "HA" is not really used anywhere else. Better name? */
    public static final byte HA_BACKUP_REGISTRATION = 113;
 
-   public static final byte REPLICATION_FILE_ID = 120;
+   public static final byte REPLICATION_START_SYNC = 120;
 
    // Static --------------------------------------------------------
 

Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java	2011-08-05 14:58:22 UTC (rev 11139)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java	2011-08-05 14:59:02 UTC (rev 11140)
@@ -19,7 +19,7 @@
 
    public ReplicationStartSyncMessage()
    {
-      super(REPLICATION_FILE_ID);
+      super(REPLICATION_START_SYNC);
    }
 
    public ReplicationStartSyncMessage(JournalFile[] datafiles, JournalContent contentType)

Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java	2011-08-05 14:58:22 UTC (rev 11139)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java	2011-08-05 14:59:02 UTC (rev 11140)
@@ -192,7 +192,7 @@
             handleCompareDataMessage((ReplicationCompareDataMessage)packet);
             response = new NullResponseMessage();
          }
-         else if (type == PacketImpl.REPLICATION_FILE_ID)
+         else if (type == PacketImpl.REPLICATION_START_SYNC)
          {
             handleStartReplicationSynchronization((ReplicationStartSyncMessage)packet);
          }