org.apache.activemq.artemis.core.protocol.core

Interface Packet

All Known Implementing Classes:

ActiveMQExceptionMessage, BackupRegistrationMessage, BackupReplicationStartFailedMessage, BackupRequestMessage, BackupResponseMessage, CheckFailoverMessage, CheckFailoverReplyMessage, ClusterConnectMessage, ClusterConnectReplyMessage, ClusterTopologyChangeMessage, ClusterTopologyChangeMessage_V2, ClusterTopologyChangeMessage_V3, CreateQueueMessage, CreateSessionMessage, CreateSessionResponseMessage, CreateSharedQueueMessage, DisconnectConsumerMessage, DisconnectMessage, DisconnectMessage_V2, MessagePacket, NodeAnnounceMessage, NullResponseMessage, PacketImpl, PacketsConfirmedMessage, Ping, QuorumVoteMessage, QuorumVoteReplyMessage, ReattachSessionMessage, ReattachSessionResponseMessage, ReplicationAddMessage, ReplicationAddTXMessage, ReplicationCommitMessage, ReplicationDeleteMessage, ReplicationDeleteTXMessage, ReplicationLargeMessageBeginMessage, ReplicationLargeMessageEndMessage, ReplicationLargeMessageWriteMessage, ReplicationLiveIsStoppingMessage, ReplicationPageEventMessage, ReplicationPageWriteMessage, ReplicationPrepareMessage, ReplicationResponseMessage, ReplicationResponseMessageV2, ReplicationStartSyncMessage, ReplicationSyncFileMessage, RollbackMessage, ScaleDownAnnounceMessage, SessionAcknowledgeMessage, SessionAddMetaDataMessage, SessionAddMetaDataMessageV2, SessionBindingQueryMessage, SessionBindingQueryResponseMessage, SessionBindingQueryResponseMessage_V2, SessionCloseMessage, SessionCommitMessage, SessionConsumerCloseMessage, SessionConsumerFlowCreditMessage, SessionContinuationMessage, SessionCreateConsumerMessage, SessionDeleteQueueMessage, SessionExpireMessage, SessionForceConsumerDelivery, SessionIndividualAcknowledgeMessage, SessionProducerCreditsFailMessage, SessionProducerCreditsMessage, SessionQueueQueryMessage, SessionQueueQueryResponseMessage, SessionQueueQueryResponseMessage_V2, SessionReceiveClientLargeMessage, SessionReceiveContinuationMessage, SessionReceiveLargeMessage, SessionReceiveMessage, SessionRequestProducerCreditsMessage, SessionSendContinuationMessage, SessionSendLargeMessage, SessionSendMessage, SessionUniqueAddMetaDataMessage, SessionXAAfterFailedMessage, SessionXACommitMessage, SessionXAEndMessage, SessionXAForgetMessage, SessionXAGetInDoubtXidsResponseMessage, SessionXAGetTimeoutResponseMessage, SessionXAJoinMessage, SessionXAPrepareMessage, SessionXAResponseMessage, SessionXAResumeMessage, SessionXARollbackMessage, SessionXASetTimeoutMessage, SessionXASetTimeoutResponseMessage, SessionXAStartMessage, SubscribeClusterTopologyUpdatesMessage, SubscribeClusterTopologyUpdatesMessageV2

public interface Packet

A Packet represents a packet of data transmitted over a connection.

Method Summary

Modifier and Type	Method and Description
void	decode(ActiveMQBuffer buffer) decodes the buffer into this packet
ActiveMQBuffer	encode(RemotingConnection connection) Encodes the packet and returns a ActiveMQBuffer containing the data
long	getChannelID() Returns the channel id of the channel that should handle this packet.
int	getPacketSize() returns the size needed to encode this packet.
byte	getType() returns the type of the packet.
boolean	isRequiresConfirmations() returns true if a confirmation should be sent on receipt of this packet.
boolean	isResponse() returns true if this packet is being sent in response to a previously received packet
void	setChannelID(long channelID) Sets the channel id that should be used once the packet has been successfully decoded it is sent to the correct channel.

Method Detail

setChannelID

void setChannelID(long channelID)

Sets the channel id that should be used once the packet has been successfully decoded it is sent to the correct channel.

Parameters:

channelID - the id of the channel to handle the packet

getChannelID

long getChannelID()

Returns the channel id of the channel that should handle this packet.

Returns:

the id of the channel

isResponse

boolean isResponse()

returns true if this packet is being sent in response to a previously received packet

Returns:

true if a response

getType

byte getType()

returns the type of the packet.

This is needed when decoding the packet

Returns:

the packet type

encode

ActiveMQBuffer encode(RemotingConnection connection)

Encodes the packet and returns a ActiveMQBuffer containing the data

Parameters:

connection - the connection

Returns:

the buffer to encode to

decode

void decode(ActiveMQBuffer buffer)

decodes the buffer into this packet

Parameters:

buffer - the buffer to decode from

getPacketSize

int getPacketSize()

returns the size needed to encode this packet.

Returns:

The size of the entire packet including headers, and extra data

isRequiresConfirmations

boolean isRequiresConfirmations()

returns true if a confirmation should be sent on receipt of this packet.

Returns:

true if confirmation is required