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); }