public class SessionReceiveMessage extends MessagePacket
message
BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, REATTACH_SESSION, REATTACH_SESSION_RESP, REPLICATION_APPEND, REPLICATION_APPEND_TX, REPLICATION_COMMIT_ROLLBACK, REPLICATION_DELETE, REPLICATION_DELETE_TX, REPLICATION_LARGE_MESSAGE_BEGIN, REPLICATION_LARGE_MESSAGE_END, REPLICATION_LARGE_MESSAGE_WRITE, REPLICATION_PAGE_EVENT, REPLICATION_PAGE_WRITE, REPLICATION_PREPARE, REPLICATION_RESPONSE, REPLICATION_SCHEDULED_FAILOVER, REPLICATION_START_FINISH_SYNC, REPLICATION_SYNC_FILE, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_CLOSE, SESS_COMMIT, SESS_CONSUMER_CLOSE, SESS_CREATECONSUMER, SESS_EXPIRED, SESS_FLOWTOKEN, SESS_FORCE_CONSUMER_DELIVERY, SESS_INDIVIDUAL_ACKNOWLEDGE, SESS_PRODUCER_CREDITS, SESS_PRODUCER_FAIL_CREDITS, SESS_PRODUCER_REQUEST_CREDITS, SESS_QUEUEQUERY, SESS_QUEUEQUERY_RESP, SESS_RECEIVE_CONTINUATION, SESS_RECEIVE_LARGE_MSG, SESS_RECEIVE_MSG, SESS_ROLLBACK, SESS_SEND, SESS_SEND_CONTINUATION, SESS_SEND_LARGE, SESS_START, SESS_STOP, SESS_UNIQUE_ADD_METADATA, SESS_XA_COMMIT, SESS_XA_END, SESS_XA_FAILED, SESS_XA_FORGET, SESS_XA_GET_TIMEOUT, SESS_XA_GET_TIMEOUT_RESP, SESS_XA_INDOUBT_XIDS, SESS_XA_INDOUBT_XIDS_RESP, SESS_XA_JOIN, SESS_XA_PREPARE, SESS_XA_RESP, SESS_XA_RESUME, SESS_XA_ROLLBACK, SESS_XA_SET_TIMEOUT, SESS_XA_SET_TIMEOUT_RESP, SESS_XA_START, SESS_XA_SUSPEND, size, SUBSCRIBE_TOPOLOGY, SUBSCRIBE_TOPOLOGY_V2
Constructor and Description |
---|
SessionReceiveMessage(long consumerID,
MessageInternal message,
int deliveryCount) |
SessionReceiveMessage(MessageInternal message) |
Modifier and Type | Method and Description |
---|---|
void |
decode(HornetQBuffer buffer)
decodes the buffer into this packet
|
HornetQBuffer |
encode(RemotingConnection connection)
Encodes the packet and returns a
HornetQBuffer containing the data |
boolean |
equals(Object obj) |
long |
getConsumerID() |
int |
getDeliveryCount() |
int |
hashCode() |
getMessage, toString
decodeRest, encodeRest, getChannelID, getPacketSize, getParentString, getType, isAsyncExec, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID
public SessionReceiveMessage(long consumerID, MessageInternal message, int deliveryCount)
public SessionReceiveMessage(MessageInternal message)
public long getConsumerID()
public int getDeliveryCount()
public HornetQBuffer encode(RemotingConnection connection)
Packet
HornetQBuffer
containing the dataencode
in interface Packet
encode
in class PacketImpl
connection
- the connectionpublic void decode(HornetQBuffer buffer)
Packet
decode
in interface Packet
decode
in class PacketImpl
buffer
- the buffer to decode frompublic int hashCode()
hashCode
in class PacketImpl
public boolean equals(Object obj)
equals
in class PacketImpl
Copyright © 2018 JBoss by Red Hat. All rights reserved.