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

Class SessionSendContinuationMessage

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

All Implemented Interfaces:

Packet

Direct Known Subclasses:

SessionSendContinuationMessage_V2

public class SessionSendContinuationMessage
extends SessionContinuationMessage

Field Summary

Fields

Modifier and Type	Field	Description
protected Message	message
protected long	messageBodySize	to be sent on the last package
protected boolean	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_18_0_VERSION, ARTEMIS_2_21_0_VERSION, ARTEMIS_2_24_0_VERSION, ARTEMIS_2_28_0_VERSION, ARTEMIS_2_29_0_VERSION, ARTEMIS_2_37_0_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, CLUSTER_TOPOLOGY_V4, CONSUMER_PRIORITY_CHANGE_VERSION, CREATE_ADDRESS, CREATE_PRODUCER, CREATE_QUEUE, CREATE_QUEUE_V2, CREATE_SHARED_QUEUE, CREATE_SHARED_QUEUE_V2, CREATESESSION, CREATESESSION_RESP, CREATESESSION_V2, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, DISCONNECT_V3, 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, REMOVE_PRODUCER, 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_BINDINGQUERY_RESP_V5, 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

Modifier	Constructor	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)

Method Summary

Modifier and Type	Method	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()
protected String	getPacketString()
int	getSenderID()
int	hashCode()
boolean	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, getCorrelationID, getPacketSize, getType, isRequiresConfirmations, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID, toString

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

Field Details

requiresResponse

protected boolean requiresResponse

message

protected Message message

messageBodySize

protected long messageBodySize

to be sent on the last package

Constructor Details

SessionSendContinuationMessage

public SessionSendContinuationMessage()

SessionSendContinuationMessage

protected SessionSendContinuationMessage(byte type)

SessionSendContinuationMessage

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

SessionSendContinuationMessage

protected SessionSendContinuationMessage(byte type,
 Message message,
 byte[] body,
 boolean continues,
 boolean requiresResponse,
 long messageBodySize,
 SendAcknowledgementHandler handler)

Method Details

isRequiresResponse

public boolean isRequiresResponse()

Specified by:

isRequiresResponse in interface Packet

Overrides:

isRequiresResponse in class PacketImpl

getMessageBodySize

public long getMessageBodySize()

getMessage

public Message getMessage()

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 SessionContinuationMessage

Returns:

the size in bytes of the expected encoded packet

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class SessionContinuationMessage

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionContinuationMessage

hashCode

public int hashCode()

Overrides:

hashCode in class SessionContinuationMessage

getPacketString

protected String getPacketString()

Overrides:

getPacketString in class SessionContinuationMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionContinuationMessage

getHandler

public SendAcknowledgementHandler getHandler()

getSenderID

public int getSenderID()