Author: borges Date: 2011-08-05 11:07:05 -0400 (Fri, 05 Aug 2011) New Revision: 11143 Removed: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/CreateReplicationSessionMessage.java 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 Log: HORNETQ-720 Get rid of createReplication left-overs 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 15:01:37 UTC (rev 11142) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java 2011-08-05 15:07:05 UTC (rev 11143) @@ -17,7 +17,6 @@ import static org.hornetq.core.protocol.core.impl.PacketImpl.CREATESESSION; import static org.hornetq.core.protocol.core.impl.PacketImpl.CREATESESSION_RESP; import static org.hornetq.core.protocol.core.impl.PacketImpl.CREATE_QUEUE; -import static org.hornetq.core.protocol.core.impl.PacketImpl.CREATE_REPLICATION; import static org.hornetq.core.protocol.core.impl.PacketImpl.DELETE_QUEUE; import static org.hornetq.core.protocol.core.impl.PacketImpl.DISCONNECT; import static org.hornetq.core.protocol.core.impl.PacketImpl.EXCEPTION; @@ -88,7 +87,6 @@ import org.hornetq.core.protocol.core.Packet; import org.hornetq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage; import org.hornetq.core.protocol.core.impl.wireformat.CreateQueueMessage; -import org.hornetq.core.protocol.core.impl.wireformat.CreateReplicationSessionMessage; import org.hornetq.core.protocol.core.impl.wireformat.CreateSessionMessage; import org.hornetq.core.protocol.core.impl.wireformat.CreateSessionResponseMessage; import org.hornetq.core.protocol.core.impl.wireformat.DisconnectMessage; @@ -106,7 +104,6 @@ import org.hornetq.core.protocol.core.impl.wireformat.ReplicationCompareDataMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteTXMessage; -import org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationJournalFileMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageBeingMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage; @@ -115,6 +112,7 @@ import org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageWriteMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationPrepareMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationResponseMessage; +import org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage; import org.hornetq.core.protocol.core.impl.wireformat.RollbackMessage; import org.hornetq.core.protocol.core.impl.wireformat.SessionAcknowledgeMessage; import org.hornetq.core.protocol.core.impl.wireformat.SessionAddMetaDataMessage; @@ -428,11 +426,6 @@ packet = new SessionProducerCreditsMessage(); break; } - case CREATE_REPLICATION: - { - packet = new CreateReplicationSessionMessage(); - break; - } case REPLICATION_APPEND: { packet = new ReplicationAddMessage(); 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 15:01:37 UTC (rev 11142) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java 2011-08-05 15:07:05 UTC (rev 11143) @@ -69,8 +69,6 @@ public static final byte DELETE_QUEUE = 35; - public static final byte CREATE_REPLICATION = 36; - // Session public static final byte SESS_CREATECONSUMER = 40; Deleted: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/CreateReplicationSessionMessage.java =================================================================== --- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/CreateReplicationSessionMessage.java 2011-08-05 15:01:37 UTC (rev 11142) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/CreateReplicationSessionMessage.java 2011-08-05 15:07:05 UTC (rev 11143) @@ -1,75 +0,0 @@ -/* - * Copyright 2009 Red Hat, Inc. - * Red Hat licenses this file to you under the Apache License, version - * 2.0 (the "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * http://www.apache.org/licenses/LICENSE-2.0 - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - * implied. See the License for the specific language governing - * permissions and limitations under the License. - */ - -package org.hornetq.core.protocol.core.impl.wireformat; - -import org.hornetq.api.core.HornetQBuffer; -import org.hornetq.core.protocol.core.impl.PacketImpl; - -/** - * @author <a href="mailto:tim.fox@jboss.com">Clebert Suconic</a> - */ -public class CreateReplicationSessionMessage extends PacketImpl -{ - // Constants ----------------------------------------------------- - - // Attributes ---------------------------------------------------- - - private long sessionChannelID; - - // Static -------------------------------------------------------- - - // Constructors -------------------------------------------------- - - public CreateReplicationSessionMessage(final long sessionChannelID) - { - super(PacketImpl.CREATE_REPLICATION); - - this.sessionChannelID = sessionChannelID; - } - - public CreateReplicationSessionMessage() - { - super(PacketImpl.CREATE_REPLICATION); - } - - // Public -------------------------------------------------------- - - @Override - public void encodeRest(final HornetQBuffer buffer) - { - buffer.writeLong(sessionChannelID); - } - - @Override - public void decodeRest(final HornetQBuffer buffer) - { - sessionChannelID = buffer.readLong(); - } - - /** - * @return the sessionChannelID - */ - public long getSessionChannelID() - { - return sessionChannelID; - } - - // Package protected --------------------------------------------- - - // Protected ----------------------------------------------------- - - // Private ------------------------------------------------------- - - // Inner classes ------------------------------------------------- -}