public class SessionSendContinuationMessage_V2 extends SessionSendContinuationMessage
message, messageBodySize, requiresResponse
body, continues, SESSION_CONTINUATION_BASE_SIZE
ADDRESSING_CHANGE_VERSION, ARTEMIS_2_7_0_VERSION, ASYNC_RESPONSE_CHANGE_VERSION, BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, BACKUP_REQUEST, BACKUP_REQUEST_RESPONSE, channelID, CHECK_FOR_FAILOVER, CHECK_FOR_FAILOVER_REPLY, CLUSTER_CONNECT, CLUSTER_CONNECT_REPLY, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CLUSTER_TOPOLOGY_V3, CONSUMER_PRIORITY_CHANGE_VERSION, CREATE_ADDRESS, CREATE_QUEUE, CREATE_QUEUE_V2, CREATE_SHARED_QUEUE, CREATE_SHARED_QUEUE_V2, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, EXCEPTION, FQQN_CHANGE_VERSION, NODE_ANNOUNCE, NULL_RESPONSE, OLD_QUEUE_PREFIX, OLD_TEMP_QUEUE_PREFIX, OLD_TEMP_TOPIC_PREFIX, OLD_TOPIC_PREFIX, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, QUORUM_VOTE, QUORUM_VOTE_REPLY, 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_RESPONSE_V2, REPLICATION_SCHEDULED_FAILOVER, REPLICATION_START_FINISH_SYNC, REPLICATION_SYNC_FILE, SCALEDOWN_ANNOUNCEMENT, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_BINDINGQUERY_RESP_V2, SESS_BINDINGQUERY_RESP_V3, SESS_BINDINGQUERY_RESP_V4, 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_QUEUEQUERY_RESP_V2, SESS_QUEUEQUERY_RESP_V3, 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
INITIAL_PACKET_SIZE
Constructor and Description |
---|
SessionSendContinuationMessage_V2() |
SessionSendContinuationMessage_V2(Message message,
byte[] body,
boolean continues,
boolean requiresResponse,
long messageBodySize,
SendAcknowledgementHandler handler) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(ActiveMQBuffer buffer) |
void |
encodeRest(ActiveMQBuffer buffer) |
boolean |
equals(Object obj) |
int |
expectedEncodeSize()
Returns the exact expected encoded size of
this packet. |
long |
getCorrelationID() |
int |
hashCode() |
boolean |
isResponseAsync() |
void |
setCorrelationID(long correlationID) |
String |
toString() |
getHandler, getMessage, getMessageBodySize, isRequiresResponse
getBody, isContinues
convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID
public SessionSendContinuationMessage_V2()
public SessionSendContinuationMessage_V2(Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
body
- continues
- requiresResponse
- public int expectedEncodeSize()
SessionContinuationMessage
this
packet.
It will be used to allocate the proper encoding buffer in PacketImpl.createPacket(org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection)
, hence any
wrong value will result in a thrown exception or a resize of the encoding
buffer during the encoding process, depending to the implementation of PacketImpl.createPacket(org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection)
.
Any child of this
class are required to override this method if their encoded size is changed
from the base class.expectedEncodeSize
in interface Packet
expectedEncodeSize
in class SessionSendContinuationMessage
public void encodeRest(ActiveMQBuffer buffer)
encodeRest
in class SessionSendContinuationMessage
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class SessionSendContinuationMessage
public long getCorrelationID()
getCorrelationID
in interface Packet
getCorrelationID
in class PacketImpl
public void setCorrelationID(long correlationID)
setCorrelationID
in interface Packet
setCorrelationID
in class PacketImpl
public boolean isResponseAsync()
isResponseAsync
in interface Packet
isResponseAsync
in class PacketImpl
public int hashCode()
hashCode
in class SessionSendContinuationMessage
public String toString()
toString
in class SessionSendContinuationMessage
public boolean equals(Object obj)
equals
in class SessionSendContinuationMessage
Copyright © 2019 JBoss by Red Hat. All rights reserved.