Uses of Interface
org.apache.activemq.artemis.core.protocol.core.Packet

Packages that use Packet

Package	Description
org.apache.activemq.artemis.core.protocol
org.apache.activemq.artemis.core.protocol.core
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.protocol.core.impl.wireformat
org.apache.activemq.artemis.core.protocol.hornetq
org.apache.activemq.artemis.core.protocol.hornetq.client
org.apache.activemq.artemis.core.protocol.hornetq.util
org.apache.activemq.artemis.core.replication
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.quorum

Uses of Packet in org.apache.activemq.artemis.core.protocol

Methods in org.apache.activemq.artemis.core.protocol that return Packet

Modifier and Type	Method	Description
Packet	ClientPacketDecoder.decode(byte packetType, CoreRemotingConnection connection)
Packet	ClientPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)
Packet	ServerPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)

Uses of Packet in org.apache.activemq.artemis.core.protocol.core

Methods in org.apache.activemq.artemis.core.protocol.core that return Packet

Modifier and Type	Method	Description
Packet	Channel.sendBlocking(Packet packet, byte expectedPacket)	Sends a packet on this channel and then blocks until a response is received or a timeout occurs.
Packet	Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket)	Sends a packet on this channel and then blocks until a response is received or a timeout occurs.
Packet	Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout)

Methods in org.apache.activemq.artemis.core.protocol.core with parameters of type Packet

Modifier and Type	Method	Description
void	CommandConfirmationHandler.commandConfirmed(Packet packet)	called by channel after a confirmation has been received.
void	Channel.confirm(Packet packet)	sends a confirmation of a packet being received.
void	Channel.handlePacket(Packet packet)	Called by CoreRemotingConnection when a packet is received.
void	ChannelHandler.handlePacket(Packet packet)	called by the channel when a packet is received..
void	ServerSessionPacketHandler.handlePacket(Packet packet)
void	ResponseHandler.handleResponse(Packet packet, Packet response)	called by channel after an async response has been received.
boolean	Channel.send(Packet packet)	Sends a packet on this channel.
boolean	Channel.send(Packet packet, boolean flushConnection)	Sends a packet on this channel, but request it to be flushed (along with the un-flushed previous ones) only iff flushConnection is true.
boolean	Channel.send(Packet packet, int reconnectID)	Sends a packet on this channel.
boolean	Channel.sendAndFlush(Packet packet)	Sends a packet on this channel and then blocks until it has been written to the connection.
boolean	Channel.sendBatched(Packet packet)	Sends a packet on this channel using batching algorithm if appropriate
Packet	Channel.sendBlocking(Packet packet, byte expectedPacket)	Sends a packet on this channel and then blocks until a response is received or a timeout occurs.
Packet	Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket)	Sends a packet on this channel and then blocks until a response is received or a timeout occurs.
Packet	Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout)

Uses of Packet in org.apache.activemq.artemis.core.protocol.core.impl

Classes in org.apache.activemq.artemis.core.protocol.core.impl that implement Packet

Modifier and Type	Class	Description
class	PacketImpl

Methods in org.apache.activemq.artemis.core.protocol.core.impl that return Packet

Modifier and Type	Method	Description
Packet	PacketDecoder.decode(byte packetType, CoreRemotingConnection connection)
abstract Packet	PacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)
protected Packet	ActiveMQClientProtocolManager.newCreateSessionPacket(int clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, long sessionChannelID, String clientID)
Packet	ResponseCache.remove(long correlationID)
Packet	ChannelImpl.sendBlocking(Packet packet, byte expectedPacket)
Packet	ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket)
Packet	ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout)	Due to networking issues or server issues the server may take longer to answer than expected.. the client may timeout the call throwing an exception and the client could eventually retry another call, but the server could then answer a previous command issuing a class-cast-exception.

Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type Packet

Modifier and Type	Method	Description
boolean	ResponseCache.add(Packet packet)
void	ChannelImpl.confirm(Packet packet)
void	ChannelImpl.handleAsyncResponse(Packet packet)
void	ActiveMQPacketHandler.handlePacket(Packet packet)
void	ChannelImpl.handlePacket(Packet packet)
void	ResponseCache.handleResponse(Packet response)
static String	ChannelImpl.invokeInterceptors(Packet packet, List<Interceptor> interceptors, RemotingConnection connection)	Returns the name of the interceptor that returned false or null if no interceptors returned false.
boolean	ChannelImpl.send(Packet packet)
boolean	ChannelImpl.send(Packet packet, boolean flushConnection)
boolean	ChannelImpl.send(Packet packet, int reconnectID)
boolean	ChannelImpl.sendAndFlush(Packet packet)
boolean	ChannelImpl.sendBatched(Packet packet)
Packet	ChannelImpl.sendBlocking(Packet packet, byte expectedPacket)
Packet	ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket)
Packet	ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout)	Due to networking issues or server issues the server may take longer to answer than expected.. the client may timeout the call throwing an exception and the client could eventually retry another call, but the server could then answer a previous command issuing a class-cast-exception.

Uses of Packet in org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Classes in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that implement Packet

Modifier and Type	Class	Description
class	ActiveMQExceptionMessage
class	ActiveMQExceptionMessage_V2
final class	BackupRegistrationMessage	Registers a given backup-server as the replicating backup of a primary server (i.e. a regular ActiveMQ).
final class	BackupReplicationStartFailedMessage	Informs the Backup trying to start replicating of an error.
class	BackupRequestMessage
class	BackupResponseMessage
class	CheckFailoverMessage
class	CheckFailoverReplyMessage
class	ClusterConnectMessage
class	ClusterConnectReplyMessage
class	ClusterTopologyChangeMessage
class	ClusterTopologyChangeMessage_V2
class	ClusterTopologyChangeMessage_V3
class	ClusterTopologyChangeMessage_V4
class	CreateAddressMessage
class	CreateProducerMessage
class	CreateQueueMessage
class	CreateQueueMessage_V2
class	CreateSessionMessage
class	CreateSessionMessage_V2
class	CreateSessionResponseMessage
class	CreateSharedQueueMessage
class	CreateSharedQueueMessage_V2
class	DisconnectConsumerMessage
class	DisconnectConsumerWithKillMessage
class	DisconnectMessage
class	DisconnectMessage_V2
class	DisconnectMessage_V3
class	FederationDownstreamConnectMessage
class	FederationStreamConnectMessage<T extends FederationStreamConfiguration>
class	MessagePacket
class	NodeAnnounceMessage
class	NullResponseMessage
class	NullResponseMessage_V2
class	PacketsConfirmedMessage
final class	Ping	Ping is sent on the client side by ClientSessionFactoryImpl.
class	QueueAbstractPacket
class	QuorumVoteMessage
class	QuorumVoteReplyMessage
class	ReattachSessionMessage
class	ReattachSessionResponseMessage
class	RemoveProducerMessage
final class	ReplicationAddMessage
class	ReplicationAddTXMessage
final class	ReplicationCommitMessage
final class	ReplicationDeleteMessage
class	ReplicationDeleteTXMessage
class	ReplicationLargeMessageBeginMessage
class	ReplicationLargeMessageEndMessage
final class	ReplicationLargeMessageWriteMessage
class	ReplicationPageEventMessage
class	ReplicationPageWriteMessage
final class	ReplicationPrepareMessage
final class	ReplicationPrimaryIsStoppingMessage	Message indicating that the primary is stopping (a scheduled stop).
class	ReplicationResponseMessage
final class	ReplicationResponseMessageV2
class	ReplicationStartSyncMessage	This message may signal start or end of the replication synchronization.
final class	ReplicationSyncFileMessage	Message is used to sync SequentialFiles to a backup server.
class	RollbackMessage
class	ScaleDownAnnounceMessage
class	SessionAcknowledgeMessage
class	SessionAddMetaDataMessage	A SessionAddMetaDataMessage
class	SessionAddMetaDataMessageV2	A SessionAddMetaDataMessage
class	SessionBindingQueryMessage
class	SessionBindingQueryResponseMessage
class	SessionBindingQueryResponseMessage_V2
class	SessionBindingQueryResponseMessage_V3
class	SessionBindingQueryResponseMessage_V4
class	SessionBindingQueryResponseMessage_V5
class	SessionCloseMessage
class	SessionCommitMessage
class	SessionCommitMessage_V2
class	SessionConsumerCloseMessage
class	SessionConsumerFlowCreditMessage
class	SessionContinuationMessage
class	SessionCreateConsumerMessage
class	SessionDeleteQueueMessage
class	SessionExpireMessage
class	SessionForceConsumerDelivery
class	SessionIndividualAcknowledgeMessage
class	SessionProducerCreditsFailMessage
class	SessionProducerCreditsMessage
class	SessionQueueQueryMessage
class	SessionQueueQueryResponseMessage
class	SessionQueueQueryResponseMessage_V2
class	SessionQueueQueryResponseMessage_V3
class	SessionReceiveClientLargeMessage
class	SessionReceiveContinuationMessage
class	SessionReceiveLargeMessage
class	SessionReceiveMessage
class	SessionReceiveMessage_1X
class	SessionRequestProducerCreditsMessage
class	SessionSendContinuationMessage
class	SessionSendContinuationMessage_V2
class	SessionSendContinuationMessage_V3
class	SessionSendLargeMessage
class	SessionSendMessage
class	SessionSendMessage_1X	SessionSend Message for the 1.x branch
class	SessionSendMessage_V2
class	SessionSendMessage_V3
class	SessionUniqueAddMetaDataMessage
class	SessionXAAfterFailedMessage	to be called after a failure on an XA Session
class	SessionXACommitMessage
class	SessionXAEndMessage
class	SessionXAForgetMessage
class	SessionXAGetInDoubtXidsResponseMessage
class	SessionXAGetTimeoutResponseMessage
class	SessionXAJoinMessage
class	SessionXAPrepareMessage
class	SessionXAResponseMessage
class	SessionXAResponseMessage_V2
class	SessionXAResumeMessage
class	SessionXARollbackMessage
class	SessionXASetTimeoutMessage
class	SessionXASetTimeoutResponseMessage
class	SessionXAStartMessage
class	SubscribeClusterTopologyUpdatesMessage
class	SubscribeClusterTopologyUpdatesMessageV2

Uses of Packet in org.apache.activemq.artemis.core.protocol.hornetq

Methods in org.apache.activemq.artemis.core.protocol.hornetq with parameters of type Packet

Modifier and Type	Method	Description
boolean	HQFilterConversionInterceptor.intercept(Packet packet, RemotingConnection connection)
boolean	HQPropertiesConversionInterceptor.intercept(Packet packet, RemotingConnection connection)

Uses of Packet in org.apache.activemq.artemis.core.protocol.hornetq.client

Methods in org.apache.activemq.artemis.core.protocol.hornetq.client that return Packet

Modifier and Type	Method	Description
protected Packet	HornetQClientProtocolManager.newCreateSessionPacket(int clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, long sessionChannelID, String clientID)

Uses of Packet in org.apache.activemq.artemis.core.protocol.hornetq.util

Methods in org.apache.activemq.artemis.core.protocol.hornetq.util with parameters of type Packet

Modifier and Type	Method	Description
static boolean	HQPropertiesConverter.isMessagePacket(Packet packet)

Uses of Packet in org.apache.activemq.artemis.core.replication

Methods in org.apache.activemq.artemis.core.replication with parameters of type Packet

Modifier and Type	Method	Description
void	ReplicationEndpoint.handlePacket(Packet packet)

Uses of Packet in org.apache.activemq.artemis.core.server

Methods in org.apache.activemq.artemis.core.server with parameters of type Packet

Modifier and Type	Method	Description
void	ActiveMQServerLogger_impl.errorHandlingReplicationPacket(Packet packet, Exception e)
void	ActiveMQServerLogger.errorHandlingReplicationPacket(Packet packet, Exception e)
void	ActiveMQServerLogger_impl.invalidPacket(Packet packet)
void	ActiveMQServerLogger.invalidPacket(Packet packet)
void	ActiveMQServerLogger_impl.invalidPacketForReplication(Packet packet)
void	ActiveMQServerLogger.invalidPacketForReplication(Packet packet)

Uses of Packet in org.apache.activemq.artemis.core.server.cluster

Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type Packet

Modifier and Type	Method	Description
boolean	ClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet, RemotingConnection connection)

Uses of Packet in org.apache.activemq.artemis.core.server.cluster.quorum

Methods in org.apache.activemq.artemis.core.server.cluster.quorum with parameters of type Packet

Modifier and Type	Method	Description
void	QuorumManager.handleQuorumVote(Channel clusterChannel, Packet packet)