public class PacketImpl extends Object implements Packet
| Constructor and Description |
|---|
PacketImpl(byte type) |
| Modifier and Type | Method and Description |
|---|---|
void |
decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
decodes the buffer into this packet
|
void |
decodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer) |
org.apache.activemq.artemis.api.core.ActiveMQBuffer |
encode(RemotingConnection connection)
Encodes the packet and returns a
ActiveMQBuffer containing the data |
void |
encodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer) |
boolean |
equals(Object obj) |
long |
getChannelID()
Returns the channel id of the channel that should handle this packet.
|
int |
getPacketSize()
returns the size needed to encode this packet.
|
protected String |
getParentString() |
byte |
getType()
returns the type of the packet.
|
int |
hashCode() |
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
|
protected int |
nullableStringEncodeSize(String str) |
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.
|
String |
toString() |
public static final int PACKET_HEADERS_SIZE
protected long channelID
protected int size
public static final byte PING
public static final byte DISCONNECT
public static final byte DISCONNECT_CONSUMER
public static final byte DISCONNECT_CONSUMER_KILL
public static final byte EXCEPTION
public static final byte NULL_RESPONSE
public static final byte PACKETS_CONFIRMED
public static final byte CREATESESSION
public static final byte CREATESESSION_RESP
public static final byte REATTACH_SESSION
public static final byte REATTACH_SESSION_RESP
public static final byte CREATE_QUEUE
public static final byte DELETE_QUEUE
public static final byte CREATE_SHARED_QUEUE
public static final byte SESS_XA_FAILED
public static final byte SESS_CREATECONSUMER
public static final byte SESS_ACKNOWLEDGE
public static final byte SESS_EXPIRED
public static final byte SESS_COMMIT
public static final byte SESS_ROLLBACK
public static final byte SESS_QUEUEQUERY
public static final byte SESS_QUEUEQUERY_RESP
public static final byte SESS_BINDINGQUERY
public static final byte SESS_BINDINGQUERY_RESP
public static final byte SESS_XA_START
public static final byte SESS_XA_END
public static final byte SESS_XA_COMMIT
public static final byte SESS_XA_PREPARE
public static final byte SESS_XA_RESP
public static final byte SESS_XA_ROLLBACK
public static final byte SESS_XA_JOIN
public static final byte SESS_XA_SUSPEND
public static final byte SESS_XA_RESUME
public static final byte SESS_XA_FORGET
public static final byte SESS_XA_INDOUBT_XIDS
public static final byte SESS_XA_INDOUBT_XIDS_RESP
public static final byte SESS_XA_SET_TIMEOUT
public static final byte SESS_XA_SET_TIMEOUT_RESP
public static final byte SESS_XA_GET_TIMEOUT
public static final byte SESS_XA_GET_TIMEOUT_RESP
public static final byte SESS_START
public static final byte SESS_STOP
public static final byte SESS_CLOSE
public static final byte SESS_FLOWTOKEN
public static final byte SESS_SEND
public static final byte SESS_SEND_LARGE
public static final byte SESS_SEND_CONTINUATION
public static final byte SESS_CONSUMER_CLOSE
public static final byte SESS_RECEIVE_MSG
public static final byte SESS_RECEIVE_LARGE_MSG
public static final byte SESS_RECEIVE_CONTINUATION
public static final byte SESS_FORCE_CONSUMER_DELIVERY
public static final byte SESS_PRODUCER_REQUEST_CREDITS
public static final byte SESS_PRODUCER_CREDITS
public static final byte SESS_INDIVIDUAL_ACKNOWLEDGE
public static final byte SESS_PRODUCER_FAIL_CREDITS
public static final byte REPLICATION_RESPONSE
public static final byte REPLICATION_APPEND
public static final byte REPLICATION_APPEND_TX
public static final byte REPLICATION_DELETE
public static final byte REPLICATION_DELETE_TX
public static final byte REPLICATION_PREPARE
public static final byte REPLICATION_COMMIT_ROLLBACK
public static final byte REPLICATION_PAGE_WRITE
public static final byte REPLICATION_PAGE_EVENT
public static final byte REPLICATION_LARGE_MESSAGE_BEGIN
public static final byte REPLICATION_LARGE_MESSAGE_END
public static final byte REPLICATION_LARGE_MESSAGE_WRITE
public static final byte REPLICATION_SYNC_FILE
public static final byte SESS_ADD_METADATA
public static final byte SESS_ADD_METADATA2
public static final byte SESS_UNIQUE_ADD_METADATA
public static final byte CLUSTER_TOPOLOGY
public static final byte NODE_ANNOUNCE
public static final byte SUBSCRIBE_TOPOLOGY
public static final byte SUBSCRIBE_TOPOLOGY_V2
public static final byte CLUSTER_TOPOLOGY_V2
public static final byte BACKUP_REGISTRATION
public static final byte BACKUP_REGISTRATION_FAILED
public static final byte REPLICATION_START_FINISH_SYNC
public static final byte REPLICATION_SCHEDULED_FAILOVER
public static final byte CLUSTER_TOPOLOGY_V3
public static final byte DISCONNECT_V2
public static final byte CLUSTER_CONNECT
public static final byte CLUSTER_CONNECT_REPLY
public static final byte BACKUP_REQUEST
public static final byte BACKUP_REQUEST_RESPONSE
public static final byte QUORUM_VOTE
public static final byte QUORUM_VOTE_REPLY
public static final byte CHECK_FOR_FAILOVER
public static final byte CHECK_FOR_FAILOVER_REPLY
public static final byte SCALEDOWN_ANNOUNCEMENT
public static final byte SESS_QUEUEQUERY_RESP_V2
public static final byte SESS_BINDINGQUERY_RESP_V2
public static final byte REPLICATION_RESPONSE_V2
public static final byte SESS_BINDINGQUERY_RESP_V3
public byte getType()
PacketThis is needed when decoding the packet
public long getChannelID()
PacketgetChannelID in interface Packetpublic void setChannelID(long channelID)
PacketsetChannelID in interface PacketchannelID - the id of the channel to handle the packetpublic org.apache.activemq.artemis.api.core.ActiveMQBuffer encode(RemotingConnection connection)
PacketActiveMQBuffer containing the datapublic void decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
Packetpublic int getPacketSize()
PacketgetPacketSize in interface Packetpublic boolean isResponse()
PacketisResponse in interface Packetpublic void encodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
public void decodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
public boolean isRequiresConfirmations()
PacketisRequiresConfirmations in interface Packetprotected String getParentString()
protected int nullableStringEncodeSize(String str)
Copyright © 2023 The Apache Software Foundation. All rights reserved.