http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManager.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManager.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManager.java index 19b48a8..f47078c 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManager.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManager.java @@ -11,7 +11,7 @@ * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl; +package org.apache.activemq.core.protocol.core.impl; import java.util.List; import java.util.concurrent.CountDownLatch; @@ -19,43 +19,43 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Lock; import io.netty.channel.ChannelPipeline; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.HornetQException; -import org.apache.activemq6.api.core.HornetQExceptionType; -import org.apache.activemq6.api.core.HornetQInterruptedException; -import org.apache.activemq6.api.core.Interceptor; -import org.apache.activemq6.api.core.Pair; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.api.core.TransportConfiguration; -import org.apache.activemq6.api.core.client.ClientSessionFactory; -import org.apache.activemq6.api.core.client.HornetQClient; -import org.apache.activemq6.core.client.HornetQClientLogger; -import org.apache.activemq6.core.client.HornetQClientMessageBundle; -import org.apache.activemq6.core.client.impl.ClientSessionFactoryInternal; -import org.apache.activemq6.core.protocol.ClientPacketDecoder; -import org.apache.activemq6.core.protocol.core.Channel; -import org.apache.activemq6.core.protocol.core.ChannelHandler; -import org.apache.activemq6.core.protocol.core.CoreRemotingConnection; -import org.apache.activemq6.core.protocol.core.Packet; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CheckFailoverMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CheckFailoverReplyMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V2; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V3; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateSessionMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateSessionResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectMessage_V2; -import org.apache.activemq6.core.protocol.core.impl.wireformat.Ping; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessageV2; -import org.apache.activemq6.core.remoting.impl.netty.HornetQFrameDecoder2; -import org.apache.activemq6.core.version.Version; -import org.apache.activemq6.spi.core.protocol.RemotingConnection; -import org.apache.activemq6.spi.core.remoting.ClientProtocolManager; -import org.apache.activemq6.spi.core.remoting.Connection; -import org.apache.activemq6.spi.core.remoting.TopologyResponseHandler; -import org.apache.activemq6.spi.core.remoting.SessionContext; -import org.apache.activemq6.utils.VersionLoader; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.HornetQException; +import org.apache.activemq.api.core.HornetQExceptionType; +import org.apache.activemq.api.core.HornetQInterruptedException; +import org.apache.activemq.api.core.Interceptor; +import org.apache.activemq.api.core.Pair; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.api.core.TransportConfiguration; +import org.apache.activemq.api.core.client.ClientSessionFactory; +import org.apache.activemq.api.core.client.HornetQClient; +import org.apache.activemq.core.client.HornetQClientLogger; +import org.apache.activemq.core.client.HornetQClientMessageBundle; +import org.apache.activemq.core.client.impl.ClientSessionFactoryInternal; +import org.apache.activemq.core.protocol.ClientPacketDecoder; +import org.apache.activemq.core.protocol.core.Channel; +import org.apache.activemq.core.protocol.core.ChannelHandler; +import org.apache.activemq.core.protocol.core.CoreRemotingConnection; +import org.apache.activemq.core.protocol.core.Packet; +import org.apache.activemq.core.protocol.core.impl.wireformat.CheckFailoverMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CheckFailoverReplyMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V2; +import org.apache.activemq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V3; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateSessionMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateSessionResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectMessage_V2; +import org.apache.activemq.core.protocol.core.impl.wireformat.Ping; +import org.apache.activemq.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessageV2; +import org.apache.activemq.core.remoting.impl.netty.HornetQFrameDecoder2; +import org.apache.activemq.core.version.Version; +import org.apache.activemq.spi.core.protocol.RemotingConnection; +import org.apache.activemq.spi.core.remoting.ClientProtocolManager; +import org.apache.activemq.spi.core.remoting.Connection; +import org.apache.activemq.spi.core.remoting.TopologyResponseHandler; +import org.apache.activemq.spi.core.remoting.SessionContext; +import org.apache.activemq.utils.VersionLoader; /** * This class will return specific packets for different types of actions happening on a messaging protocol.
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManagerFactory.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManagerFactory.java index 09b91c3..103e20d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManagerFactory.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQClientProtocolManagerFactory.java @@ -11,10 +11,10 @@ * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl; +package org.apache.activemq.core.protocol.core.impl; -import org.apache.activemq6.spi.core.remoting.ClientProtocolManager; -import org.apache.activemq6.spi.core.remoting.ClientProtocolManagerFactory; +import org.apache.activemq.spi.core.remoting.ClientProtocolManager; +import org.apache.activemq.spi.core.remoting.ClientProtocolManagerFactory; /** * @author Clebert Suconic http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQConsumerContext.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQConsumerContext.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQConsumerContext.java index c4967f1..27585e8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQConsumerContext.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQConsumerContext.java @@ -11,9 +11,9 @@ * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl; +package org.apache.activemq.core.protocol.core.impl; -import org.apache.activemq6.spi.core.remoting.ConsumerContext; +import org.apache.activemq.spi.core.remoting.ConsumerContext; /** * @author Clebert Suconic http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQSessionContext.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQSessionContext.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQSessionContext.java index 2ec884d..2cc14ee 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQSessionContext.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/HornetQSessionContext.java @@ -11,7 +11,7 @@ * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl; +package org.apache.activemq.core.protocol.core.impl; import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; @@ -23,85 +23,85 @@ import java.util.List; import java.util.Map; import java.util.concurrent.Executor; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.HornetQException; -import org.apache.activemq6.api.core.HornetQExceptionType; -import org.apache.activemq6.api.core.Message; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.api.core.client.ClientConsumer; -import org.apache.activemq6.api.core.client.ClientSession; -import org.apache.activemq6.api.core.client.SendAcknowledgementHandler; -import org.apache.activemq6.core.client.HornetQClientLogger; -import org.apache.activemq6.core.client.HornetQClientMessageBundle; -import org.apache.activemq6.core.client.impl.AddressQueryImpl; -import org.apache.activemq6.core.client.impl.ClientConsumerImpl; -import org.apache.activemq6.core.client.impl.ClientConsumerInternal; -import org.apache.activemq6.core.client.impl.ClientLargeMessageInternal; -import org.apache.activemq6.core.client.impl.ClientMessageInternal; -import org.apache.activemq6.core.client.impl.ClientProducerCreditsImpl; -import org.apache.activemq6.core.client.impl.ClientSessionImpl; -import org.apache.activemq6.core.message.impl.MessageInternal; -import org.apache.activemq6.core.protocol.core.Channel; -import org.apache.activemq6.core.protocol.core.ChannelHandler; -import org.apache.activemq6.core.protocol.core.CommandConfirmationHandler; -import org.apache.activemq6.core.protocol.core.CoreRemotingConnection; -import org.apache.activemq6.core.protocol.core.Packet; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateQueueMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateSessionMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateSharedQueueMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectConsumerMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.HornetQExceptionMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ReattachSessionMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ReattachSessionResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.RollbackMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionAcknowledgeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionAddMetaDataMessageV2; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionBindingQueryMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionBindingQueryResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionCloseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionConsumerCloseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionConsumerFlowCreditMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionCreateConsumerMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionDeleteQueueMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionExpireMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionForceConsumerDelivery; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionIndividualAcknowledgeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionProducerCreditsFailMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionProducerCreditsMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionQueueQueryMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionReceiveLargeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionReceiveMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionRequestProducerCreditsMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionSendContinuationMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionSendLargeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionSendMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionUniqueAddMetaDataMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAAfterFailedMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXACommitMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAEndMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAForgetMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAGetInDoubtXidsResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAGetTimeoutResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAJoinMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAPrepareMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAResumeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXARollbackMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXASetTimeoutMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXASetTimeoutResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAStartMessage; -import org.apache.activemq6.spi.core.protocol.RemotingConnection; -import org.apache.activemq6.spi.core.remoting.Connection; -import org.apache.activemq6.spi.core.remoting.SessionContext; -import org.apache.activemq6.utils.TokenBucketLimiterImpl; - -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.DISCONNECT_CONSUMER; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.EXCEPTION; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_CONTINUATION; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_LARGE_MSG; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_MSG; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.HornetQException; +import org.apache.activemq.api.core.HornetQExceptionType; +import org.apache.activemq.api.core.Message; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.api.core.client.ClientConsumer; +import org.apache.activemq.api.core.client.ClientSession; +import org.apache.activemq.api.core.client.SendAcknowledgementHandler; +import org.apache.activemq.core.client.HornetQClientLogger; +import org.apache.activemq.core.client.HornetQClientMessageBundle; +import org.apache.activemq.core.client.impl.AddressQueryImpl; +import org.apache.activemq.core.client.impl.ClientConsumerImpl; +import org.apache.activemq.core.client.impl.ClientConsumerInternal; +import org.apache.activemq.core.client.impl.ClientLargeMessageInternal; +import org.apache.activemq.core.client.impl.ClientMessageInternal; +import org.apache.activemq.core.client.impl.ClientProducerCreditsImpl; +import org.apache.activemq.core.client.impl.ClientSessionImpl; +import org.apache.activemq.core.message.impl.MessageInternal; +import org.apache.activemq.core.protocol.core.Channel; +import org.apache.activemq.core.protocol.core.ChannelHandler; +import org.apache.activemq.core.protocol.core.CommandConfirmationHandler; +import org.apache.activemq.core.protocol.core.CoreRemotingConnection; +import org.apache.activemq.core.protocol.core.Packet; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateQueueMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateSessionMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateSharedQueueMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectConsumerMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.HornetQExceptionMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.ReattachSessionMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.ReattachSessionResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.RollbackMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionAcknowledgeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionAddMetaDataMessageV2; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionBindingQueryMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionBindingQueryResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionCloseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionConsumerCloseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionConsumerFlowCreditMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionCreateConsumerMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionDeleteQueueMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionExpireMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionForceConsumerDelivery; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionIndividualAcknowledgeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionProducerCreditsFailMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionProducerCreditsMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionQueueQueryMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionReceiveLargeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionReceiveMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionRequestProducerCreditsMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionSendContinuationMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionSendLargeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionSendMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionUniqueAddMetaDataMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAAfterFailedMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXACommitMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAEndMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAForgetMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAGetInDoubtXidsResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAGetTimeoutResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAJoinMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAPrepareMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAResumeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXARollbackMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXASetTimeoutMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXASetTimeoutResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAStartMessage; +import org.apache.activemq.spi.core.protocol.RemotingConnection; +import org.apache.activemq.spi.core.remoting.Connection; +import org.apache.activemq.spi.core.remoting.SessionContext; +import org.apache.activemq.utils.TokenBucketLimiterImpl; + +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.DISCONNECT_CONSUMER; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.EXCEPTION; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_CONTINUATION; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_LARGE_MSG; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_MSG; /** * @author Clebert Suconic http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java index c13a4e8..908f483 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java @@ -10,132 +10,132 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl; +package org.apache.activemq.core.protocol.core.impl; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CLUSTER_TOPOLOGY; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CLUSTER_TOPOLOGY_V2; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CLUSTER_TOPOLOGY_V3; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CREATESESSION; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CREATESESSION_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CREATE_QUEUE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CREATE_SHARED_QUEUE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.DELETE_QUEUE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.DISCONNECT; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.DISCONNECT_V2; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.DISCONNECT_CONSUMER; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.EXCEPTION; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.NULL_RESPONSE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.PACKETS_CONFIRMED; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.PING; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.REATTACH_SESSION; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.REATTACH_SESSION_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.CHECK_FOR_FAILOVER; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_ACKNOWLEDGE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_ADD_METADATA; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_ADD_METADATA2; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_BINDINGQUERY; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_BINDINGQUERY_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_CLOSE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_COMMIT; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_CONSUMER_CLOSE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_CREATECONSUMER; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_EXPIRED; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_FLOWTOKEN; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_FORCE_CONSUMER_DELIVERY; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_INDIVIDUAL_ACKNOWLEDGE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_PRODUCER_CREDITS; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_PRODUCER_FAIL_CREDITS; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_PRODUCER_REQUEST_CREDITS; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_QUEUEQUERY; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_QUEUEQUERY_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_CONTINUATION; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_ROLLBACK; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_SEND_CONTINUATION; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_START; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_STOP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_UNIQUE_ADD_METADATA; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_COMMIT; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_END; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_FAILED; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_FORGET; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_GET_TIMEOUT; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_GET_TIMEOUT_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_INDOUBT_XIDS; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_INDOUBT_XIDS_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_JOIN; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_PREPARE; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_RESUME; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_ROLLBACK; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_SET_TIMEOUT; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_SET_TIMEOUT_RESP; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_START; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SESS_XA_SUSPEND; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SUBSCRIBE_TOPOLOGY; -import static org.apache.activemq6.core.protocol.core.impl.PacketImpl.SUBSCRIBE_TOPOLOGY_V2; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CLUSTER_TOPOLOGY; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CLUSTER_TOPOLOGY_V2; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CLUSTER_TOPOLOGY_V3; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CREATESESSION; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CREATESESSION_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CREATE_QUEUE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CREATE_SHARED_QUEUE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.DELETE_QUEUE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.DISCONNECT; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.DISCONNECT_V2; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.DISCONNECT_CONSUMER; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.EXCEPTION; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.NULL_RESPONSE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.PACKETS_CONFIRMED; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.PING; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.REATTACH_SESSION; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.REATTACH_SESSION_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.CHECK_FOR_FAILOVER; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_ACKNOWLEDGE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_ADD_METADATA; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_ADD_METADATA2; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_BINDINGQUERY; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_BINDINGQUERY_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_CLOSE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_COMMIT; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_CONSUMER_CLOSE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_CREATECONSUMER; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_EXPIRED; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_FLOWTOKEN; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_FORCE_CONSUMER_DELIVERY; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_INDIVIDUAL_ACKNOWLEDGE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_PRODUCER_CREDITS; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_PRODUCER_FAIL_CREDITS; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_PRODUCER_REQUEST_CREDITS; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_QUEUEQUERY; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_QUEUEQUERY_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_CONTINUATION; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_ROLLBACK; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_SEND_CONTINUATION; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_START; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_STOP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_UNIQUE_ADD_METADATA; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_COMMIT; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_END; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_FAILED; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_FORGET; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_GET_TIMEOUT; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_GET_TIMEOUT_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_INDOUBT_XIDS; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_INDOUBT_XIDS_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_JOIN; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_PREPARE; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_RESUME; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_ROLLBACK; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_SET_TIMEOUT; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_SET_TIMEOUT_RESP; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_START; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_XA_SUSPEND; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SUBSCRIBE_TOPOLOGY; +import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SUBSCRIBE_TOPOLOGY_V2; import java.io.Serializable; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.client.HornetQClientMessageBundle; -import org.apache.activemq6.core.protocol.core.Packet; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CheckFailoverMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CheckFailoverReplyMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V2; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V3; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateQueueMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateSessionMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateSessionResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.CreateSharedQueueMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectConsumerMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectMessage_V2; -import org.apache.activemq6.core.protocol.core.impl.wireformat.HornetQExceptionMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.NullResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.PacketsConfirmedMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.Ping; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ReattachSessionMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.ReattachSessionResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.RollbackMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionAcknowledgeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionAddMetaDataMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionAddMetaDataMessageV2; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionBindingQueryMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionBindingQueryResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionCloseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionCommitMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionConsumerCloseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionConsumerFlowCreditMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionCreateConsumerMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionDeleteQueueMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionExpireMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionForceConsumerDelivery; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionIndividualAcknowledgeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionProducerCreditsFailMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionProducerCreditsMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionQueueQueryMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionRequestProducerCreditsMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionSendContinuationMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionUniqueAddMetaDataMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAAfterFailedMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXACommitMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAEndMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAForgetMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAGetInDoubtXidsResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAGetTimeoutResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAJoinMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAPrepareMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAResumeMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXARollbackMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXASetTimeoutMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXASetTimeoutResponseMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SessionXAStartMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessageV2; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.client.HornetQClientMessageBundle; +import org.apache.activemq.core.protocol.core.Packet; +import org.apache.activemq.core.protocol.core.impl.wireformat.CheckFailoverMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CheckFailoverReplyMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V2; +import org.apache.activemq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V3; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateQueueMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateSessionMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateSessionResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.CreateSharedQueueMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectConsumerMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectMessage_V2; +import org.apache.activemq.core.protocol.core.impl.wireformat.HornetQExceptionMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.NullResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.PacketsConfirmedMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.Ping; +import org.apache.activemq.core.protocol.core.impl.wireformat.ReattachSessionMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.ReattachSessionResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.RollbackMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionAcknowledgeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionAddMetaDataMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionAddMetaDataMessageV2; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionBindingQueryMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionBindingQueryResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionCloseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionCommitMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionConsumerCloseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionConsumerFlowCreditMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionCreateConsumerMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionDeleteQueueMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionExpireMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionForceConsumerDelivery; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionIndividualAcknowledgeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionProducerCreditsFailMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionProducerCreditsMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionQueueQueryMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionQueueQueryResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionRequestProducerCreditsMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionSendContinuationMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionUniqueAddMetaDataMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAAfterFailedMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXACommitMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAEndMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAForgetMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAGetInDoubtXidsResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAGetTimeoutResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAJoinMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAPrepareMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAResumeMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXARollbackMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXASetTimeoutMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXASetTimeoutResponseMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAStartMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessageV2; /** * A PacketDecoder http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java index 66f72fe..0a94621 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java @@ -10,12 +10,12 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl; +package org.apache.activemq.core.protocol.core.impl; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.Packet; -import org.apache.activemq6.spi.core.protocol.RemotingConnection; -import org.apache.activemq6.utils.DataConstants; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.Packet; +import org.apache.activemq.spi.core.protocol.RemotingConnection; +import org.apache.activemq.utils.DataConstants; /** * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java index f30f073..03a17d3 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java @@ -10,7 +10,7 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl; +package org.apache.activemq.core.protocol.core.impl; import java.util.HashSet; import java.util.List; @@ -19,21 +19,21 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executor; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.HornetQException; -import org.apache.activemq6.api.core.Interceptor; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.core.client.HornetQClientLogger; -import org.apache.activemq6.core.protocol.core.Channel; -import org.apache.activemq6.core.protocol.core.CoreRemotingConnection; -import org.apache.activemq6.core.protocol.core.Packet; -import org.apache.activemq6.core.protocol.core.impl.ChannelImpl.CHANNEL_ID; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectMessage; -import org.apache.activemq6.core.protocol.core.impl.wireformat.DisconnectMessage_V2; -import org.apache.activemq6.core.security.HornetQPrincipal; -import org.apache.activemq6.spi.core.protocol.AbstractRemotingConnection; -import org.apache.activemq6.spi.core.remoting.Connection; -import org.apache.activemq6.utils.SimpleIDGenerator; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.HornetQException; +import org.apache.activemq.api.core.Interceptor; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.core.client.HornetQClientLogger; +import org.apache.activemq.core.protocol.core.Channel; +import org.apache.activemq.core.protocol.core.CoreRemotingConnection; +import org.apache.activemq.core.protocol.core.Packet; +import org.apache.activemq.core.protocol.core.impl.ChannelImpl.CHANNEL_ID; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectMessage; +import org.apache.activemq.core.protocol.core.impl.wireformat.DisconnectMessage_V2; +import org.apache.activemq.core.security.HornetQPrincipal; +import org.apache.activemq.spi.core.protocol.AbstractRemotingConnection; +import org.apache.activemq.spi.core.remoting.Connection; +import org.apache.activemq.utils.SimpleIDGenerator; /** * @author <a href="[email protected]">Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverMessage.java index ab1ec8c..16fb2db 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; public class CheckFailoverMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java index d2fbc49..351766d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CheckFailoverReplyMessage.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; public class CheckFailoverReplyMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java index 0c3a998..52c9d44 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java @@ -10,12 +10,12 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.Pair; -import org.apache.activemq6.api.core.TransportConfiguration; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.Pair; +import org.apache.activemq.api.core.TransportConfiguration; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java index 5a1eeb9..8f8d97b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V2.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.Pair; -import org.apache.activemq6.api.core.TransportConfiguration; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.Pair; +import org.apache.activemq.api.core.TransportConfiguration; /** * Clebert Suconic http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java index 7a78e6c..e3c2b3f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.Pair; -import org.apache.activemq6.api.core.TransportConfiguration; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.Pair; +import org.apache.activemq.api.core.TransportConfiguration; /** * @author Justin Bertram http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java index 2be3e02..9c07c72 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java index ad871b3..f3abf68 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java index 76a5f54..e1540a2 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java index 12339e6..4479218 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java index e842bd8..6eb4bf4 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectConsumerMessage.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; public class DisconnectConsumerMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage.java index 12ba174..22391a2 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; public class DisconnectMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage_V2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage_V2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage_V2.java index a2714be..e7297a0 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage_V2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/DisconnectMessage_V2.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.SimpleString; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.SimpleString; public class DisconnectMessage_V2 extends DisconnectMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/HornetQExceptionMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/HornetQExceptionMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/HornetQExceptionMessage.java index ab6fe23..d8a8833 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/HornetQExceptionMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/HornetQExceptionMessage.java @@ -10,12 +10,12 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.HornetQException; -import org.apache.activemq6.api.core.HornetQExceptionType; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.HornetQException; +import org.apache.activemq.api.core.HornetQExceptionType; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java index a9c4b31..a56023e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.Message; -import org.apache.activemq6.core.message.impl.MessageInternal; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.Message; +import org.apache.activemq.core.message.impl.MessageInternal; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A MessagePacket http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java index 474f53d..a05e0fe 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java @@ -10,9 +10,9 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java index 8eb088d..e131808 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java index f2ce2a3..c0552c3 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java @@ -10,15 +10,15 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** - * Ping is sent on the client side by {@link org.apache.activemq6.core.client.impl.ClientSessionFactoryImpl}. At the server's - * side it is handled by {@link org.apache.activemq6.core.remoting.server.impl.RemotingServiceImpl} - * @see org.apache.activemq6.spi.core.protocol.RemotingConnection#checkDataReceived() + * Ping is sent on the client side by {@link org.apache.activemq.core.client.impl.ClientSessionFactoryImpl}. At the server's + * side it is handled by {@link org.apache.activemq.core.remoting.server.impl.RemotingServiceImpl} + * @see org.apache.activemq.spi.core.protocol.RemotingConnection#checkDataReceived() * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public final class Ping extends PacketImpl http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java index 0e47ac5..8a4ea74 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java index 81ed8ea..7a0473c 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java index 7c00bfc..4b6bec5 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A RollbackMessage http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java index 1a0a4bb..b8daa9e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java index 2ab3296..f545169 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A SessionAddMetaDataMessage http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java index 070bda0..b75d972 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A SessionAddMetaDataMessage http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java index 5d113e7..54a9bb7 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java @@ -10,11 +10,11 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java index 9db8727..20eb737 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java @@ -10,14 +10,14 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; import java.util.ArrayList; import java.util.List; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.api.core.SimpleString; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java index 7aaac80..f3d0882 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java @@ -10,9 +10,9 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java index 4816999..e0fd856 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java @@ -10,9 +10,9 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A SessionCommitMessage http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9a587c56/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java index a4fcfec..863c378 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java @@ -10,10 +10,10 @@ * implied. See the License for the specific language governing * permissions and limitations under the License. */ -package org.apache.activemq6.core.protocol.core.impl.wireformat; +package org.apache.activemq.core.protocol.core.impl.wireformat; -import org.apache.activemq6.api.core.HornetQBuffer; -import org.apache.activemq6.core.protocol.core.impl.PacketImpl; +import org.apache.activemq.api.core.HornetQBuffer; +import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * @author <a href="mailto:[email protected]";>Tim Fox</a>
