public class SessionSendContinuationMessage extends SessionContinuationMessage
Modifier and Type | Field and Description |
---|---|
protected Message |
message |
protected long |
messageBodySize
to be sent on the last package
|
protected boolean |
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
Modifier | Constructor and Description |
---|---|
|
SessionSendContinuationMessage() |
protected |
SessionSendContinuationMessage(byte type) |
protected |
SessionSendContinuationMessage(byte type,
Message message,
byte[] body,
boolean continues,
boolean requiresResponse,
long messageBodySize,
SendAcknowledgementHandler handler) |
|
SessionSendContinuationMessage(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. |
SendAcknowledgementHandler |
getHandler() |
Message |
getMessage() |
long |
getMessageBodySize() |
int |
hashCode() |
boolean |
isRequiresResponse() |
String |
toString() |
getBody, isContinues
convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID
protected boolean requiresResponse
protected Message message
protected long messageBodySize
public SessionSendContinuationMessage()
protected SessionSendContinuationMessage(byte type)
public SessionSendContinuationMessage(Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
body
- continues
- requiresResponse
- protected SessionSendContinuationMessage(byte type, Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
body
- continues
- requiresResponse
- public boolean isRequiresResponse()
isRequiresResponse
in interface Packet
isRequiresResponse
in class PacketImpl
public long getMessageBodySize()
public Message getMessage()
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 SessionContinuationMessage
public void encodeRest(ActiveMQBuffer buffer)
encodeRest
in class SessionContinuationMessage
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class SessionContinuationMessage
public int hashCode()
hashCode
in class SessionContinuationMessage
public String toString()
toString
in class SessionContinuationMessage
public boolean equals(Object obj)
equals
in class SessionContinuationMessage
public SendAcknowledgementHandler getHandler()
Copyright © 2019 JBoss by Red Hat. All rights reserved.