public class PacketImpl extends Object implements Packet
Constructor and Description |
---|
PacketImpl(byte type) |
Modifier and Type | Method and Description |
---|---|
void |
decode(ActiveMQBuffer buffer)
decodes the buffer into this packet
|
void |
decodeRest(ActiveMQBuffer buffer) |
ActiveMQBuffer |
encode(RemotingConnection connection)
Encodes the packet and returns a
ActiveMQBuffer containing the data |
void |
encodeRest(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 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 byte getType()
Packet
This is needed when decoding the packet
public long getChannelID()
Packet
getChannelID
in interface Packet
public void setChannelID(long channelID)
Packet
setChannelID
in interface Packet
channelID
- the id of the channel to handle the packetpublic ActiveMQBuffer encode(RemotingConnection connection)
Packet
ActiveMQBuffer
containing the datapublic void decode(ActiveMQBuffer buffer)
Packet
public int getPacketSize()
Packet
getPacketSize
in interface Packet
public boolean isResponse()
Packet
isResponse
in interface Packet
public void encodeRest(ActiveMQBuffer buffer)
public void decodeRest(ActiveMQBuffer buffer)
public boolean isRequiresConfirmations()
Packet
isRequiresConfirmations
in interface Packet
protected String getParentString()
protected int nullableStringEncodeSize(String str)
Copyright © 2016 JBoss by Red Hat. All rights reserved.