public class SessionReceiveContinuationMessage extends SessionContinuationMessage
Modifier and Type | Field and Description |
---|---|
static int |
SESSION_RECEIVE_CONTINUATION_BASE_SIZE |
body, continues, SESSION_CONTINUATION_BASE_SIZE
BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_QUEUE, CREATE_SHARED_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 |
---|
SessionReceiveContinuationMessage() |
SessionReceiveContinuationMessage(long consumerID,
byte[] body,
boolean continues,
boolean requiresResponse) |
SessionReceiveContinuationMessage(long consumerID,
byte[] body,
boolean continues,
boolean requiresResponse,
int packetSize) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(HornetQBuffer buffer) |
void |
encodeRest(HornetQBuffer buffer) |
boolean |
equals(Object obj) |
long |
getConsumerID() |
int |
getPacketSize()
returns the size needed to encode this packet.
|
int |
hashCode() |
getBody, isContinues
decode, encode, getChannelID, getParentString, getType, isAsyncExec, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, toString
public static final int SESSION_RECEIVE_CONTINUATION_BASE_SIZE
public SessionReceiveContinuationMessage()
public SessionReceiveContinuationMessage(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
consumerID
- body
- continues
- requiresResponse
- public SessionReceiveContinuationMessage(long consumerID, byte[] body, boolean continues, boolean requiresResponse, int packetSize)
public long getConsumerID()
public void encodeRest(HornetQBuffer buffer)
encodeRest
in class SessionContinuationMessage
public int getPacketSize()
Packet
getPacketSize
in interface Packet
getPacketSize
in class PacketImpl
public void decodeRest(HornetQBuffer buffer)
decodeRest
in class SessionContinuationMessage
public int hashCode()
hashCode
in class SessionContinuationMessage
public boolean equals(Object obj)
equals
in class SessionContinuationMessage
Copyright © 2013 JBoss, a division of Red Hat. All rights reserved.