org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Class SessionSendContinuationMessage_V2

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionContinuationMessage

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendContinuationMessage

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendContinuationMessage_V2

All Implemented Interfaces:

Packet

public class SessionSendContinuationMessage_V2
extends SessionSendContinuationMessage

A SessionSendContinuationMessage

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendContinuationMessage

message, messageBodySize, requiresResponse

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionContinuationMessage

body, continues, SESSION_CONTINUATION_BASE_SIZE

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

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, FEDERATION_DOWNSTREAM_CONNECT, 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

Fields inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

INITIAL_PACKET_SIZE

Constructor Summary

Constructors

Constructor and Description
SessionSendContinuationMessage_V2()
SessionSendContinuationMessage_V2(Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)

Method Summary

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()

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendContinuationMessage

getHandler, getMessage, getMessageBodySize, isRequiresResponse

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionContinuationMessage

getBody, isContinues

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

release

Constructor Detail

SessionSendContinuationMessage_V2

public SessionSendContinuationMessage_V2()

SessionSendContinuationMessage_V2

public SessionSendContinuationMessage_V2(Message message,
                                         byte[] body,
                                         boolean continues,
                                         boolean requiresResponse,
                                         long messageBodySize,
                                         SendAcknowledgementHandler handler)

Parameters:

body -

continues -

requiresResponse -

Method Detail

expectedEncodeSize

public int expectedEncodeSize()

Description copied from class: SessionContinuationMessage

Returns the exact expected encoded size of 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.

Specified by:

expectedEncodeSize in interface Packet

Overrides:

expectedEncodeSize in class SessionSendContinuationMessage

Returns:

the size in bytes of the expected encoded packet

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class SessionSendContinuationMessage

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionSendContinuationMessage

getCorrelationID

public long getCorrelationID()

Specified by:

getCorrelationID in interface Packet

Overrides:

getCorrelationID in class PacketImpl

setCorrelationID

public void setCorrelationID(long correlationID)

Specified by:

setCorrelationID in interface Packet

Overrides:

setCorrelationID in class PacketImpl

isResponseAsync

public boolean isResponseAsync()

Specified by:

isResponseAsync in interface Packet

Overrides:

isResponseAsync in class PacketImpl

hashCode

public int hashCode()

Overrides:

hashCode in class SessionSendContinuationMessage

toString

public String toString()

Overrides:

toString in class SessionSendContinuationMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionSendContinuationMessage