public class SessionSendContinuationMessage extends SessionContinuationMessage
body, continues, SESSION_CONTINUATION_BASE_SIZE
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 |
---|
SessionSendContinuationMessage() |
SessionSendContinuationMessage(MessageInternal message,
byte[] body,
boolean continues,
boolean requiresResponse) |
SessionSendContinuationMessage(MessageInternal message,
byte[] body,
boolean continues,
boolean requiresResponse,
long messageBodySize) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(HornetQBuffer buffer) |
void |
encodeRest(HornetQBuffer buffer) |
boolean |
equals(Object obj) |
MessageInternal |
getMessage() |
long |
getMessageBodySize() |
int |
hashCode() |
boolean |
isRequiresResponse() |
getBody, isContinues
decode, encode, getChannelID, getPacketSize, getParentString, getType, isAsyncExec, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, toString
public SessionSendContinuationMessage()
public SessionSendContinuationMessage(MessageInternal message, byte[] body, boolean continues, boolean requiresResponse)
body
- continues
- requiresResponse
- public SessionSendContinuationMessage(MessageInternal message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize)
body
- continues
- requiresResponse
- public boolean isRequiresResponse()
public long getMessageBodySize()
public MessageInternal getMessage()
public void encodeRest(HornetQBuffer buffer)
encodeRest
in class SessionContinuationMessage
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 by Red Hat. All Rights Reserved.