Author: borges Date: 2012-02-27 10:05:01 -0500 (Mon, 27 Feb 2012) New Revision: 12205 Added: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java Removed: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeingMessage.java Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java trunk/hornetq-core/src/main/java/org/hornetq/core/replication/ReplicationEndpoint.java trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java Log: Fix spelling in class name Being --> BeGin Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java 2012-02-27 15:04:35 UTC (rev 12204) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketDecoder.java 2012-02-27 15:05:01 UTC (rev 12205) @@ -110,7 +110,7 @@ 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.ReplicationLargeMessageBeingMessage; +import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageBeginMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageEndMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage; @@ -481,7 +481,7 @@ } case REPLICATION_LARGE_MESSAGE_BEGIN: { - packet = new ReplicationLargeMessageBeingMessage(); + packet = new ReplicationLargeMessageBeginMessage(); break; } case REPLICATION_LARGE_MESSAGE_END: Copied: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java (from rev 12204, trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeingMessage.java) =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java (rev 0) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java 2012-02-27 15:05:01 UTC (rev 12205) @@ -0,0 +1,80 @@ +/* + * 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; + +/** + * A ReplicationLargeMessageBeingMessage + * + * @author <mailto:clebert.suconic@jboss.org">Clebert Suconic</a> + * + * + */ +public class ReplicationLargeMessageBeginMessage extends PacketImpl +{ + + // Constants ----------------------------------------------------- + + // Attributes ---------------------------------------------------- + + long messageId; + + // Static -------------------------------------------------------- + + // Constructors -------------------------------------------------- + + public ReplicationLargeMessageBeginMessage(final long messageId) + { + this(); + this.messageId = messageId; + } + + public ReplicationLargeMessageBeginMessage() + { + super(PacketImpl.REPLICATION_LARGE_MESSAGE_BEGIN); + } + + // Public -------------------------------------------------------- + + @Override + public void encodeRest(final HornetQBuffer buffer) + { + buffer.writeLong(messageId); + } + + @Override + public void decodeRest(final HornetQBuffer buffer) + { + messageId = buffer.readLong(); + } + + /** + * @return the messageId + */ + public long getMessageId() + { + return messageId; + } + + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + // Private ------------------------------------------------------- + + // Inner classes ------------------------------------------------- + +} Deleted: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeingMessage.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeingMessage.java 2012-02-27 15:04:35 UTC (rev 12204) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeingMessage.java 2012-02-27 15:05:01 UTC (rev 12205) @@ -1,80 +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; - -/** - * A ReplicationLargeMessageBeingMessage - * - * @author <mailto:clebert.suconic@jboss.org">Clebert Suconic</a> - * - * - */ -public class ReplicationLargeMessageBeingMessage extends PacketImpl -{ - - // Constants ----------------------------------------------------- - - // Attributes ---------------------------------------------------- - - long messageId; - - // Static -------------------------------------------------------- - - // Constructors -------------------------------------------------- - - public ReplicationLargeMessageBeingMessage(final long messageId) - { - this(); - this.messageId = messageId; - } - - public ReplicationLargeMessageBeingMessage() - { - super(PacketImpl.REPLICATION_LARGE_MESSAGE_BEGIN); - } - - // Public -------------------------------------------------------- - - @Override - public void encodeRest(final HornetQBuffer buffer) - { - buffer.writeLong(messageId); - } - - @Override - public void decodeRest(final HornetQBuffer buffer) - { - messageId = buffer.readLong(); - } - - /** - * @return the messageId - */ - public long getMessageId() - { - return messageId; - } - - // Package protected --------------------------------------------- - - // Protected ----------------------------------------------------- - - // Private ------------------------------------------------------- - - // Inner classes ------------------------------------------------- - -} Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/replication/ReplicationEndpoint.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/core/replication/ReplicationEndpoint.java 2012-02-27 15:04:35 UTC (rev 12204) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/replication/ReplicationEndpoint.java 2012-02-27 15:05:01 UTC (rev 12205) @@ -57,7 +57,7 @@ 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.ReplicationLargeMessageBeingMessage; +import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageBeginMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageEndMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage; @@ -200,7 +200,7 @@ } else if (type == PacketImpl.REPLICATION_LARGE_MESSAGE_BEGIN) { - handleLargeMessageBegin((ReplicationLargeMessageBeingMessage) packet); + handleLargeMessageBegin((ReplicationLargeMessageBeginMessage) packet); } else if (type == PacketImpl.REPLICATION_LARGE_MESSAGE_WRITE) { @@ -660,7 +660,7 @@ /** * @param packet */ - private void handleLargeMessageBegin(final ReplicationLargeMessageBeingMessage packet) + private void handleLargeMessageBegin(final ReplicationLargeMessageBeginMessage packet) { final long id = packet.getMessageId(); createLargeMessage(id, false); Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java =================================================================== --- trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java 2012-02-27 15:04:35 UTC (rev 12204) +++ trunk/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java 2012-02-27 15:05:01 UTC (rev 12205) @@ -48,7 +48,7 @@ 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.ReplicationLargeMessageBeingMessage; +import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageBeginMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageEndMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage; import org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage; @@ -258,7 +258,7 @@ { if (enabled) { - sendReplicatePacket(new ReplicationLargeMessageBeingMessage(messageId)); + sendReplicatePacket(new ReplicationLargeMessageBeginMessage(messageId)); } }