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
A SessionSendContinuationMessage
-
-
Field Summary
Fields Modifier and Type Field Description protected Messagemessageprotected longmessageBodySizeto be sent on the last packageprotected booleanrequiresResponse-
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_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_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, 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 Modifier Constructor Description SessionSendContinuationMessage()protectedSessionSendContinuationMessage(byte type)protectedSessionSendContinuationMessage(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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddecodeRest(ActiveMQBuffer buffer)voidencodeRest(ActiveMQBuffer buffer)booleanequals(Object obj)intexpectedEncodeSize()Returns the exact expected encoded size ofthispacket.SendAcknowledgementHandlergetHandler()MessagegetMessage()longgetMessageBodySize()protected StringgetPacketString()inthashCode()booleanisRequiresResponse()-
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
-
-
-
-
Field Detail
-
requiresResponse
protected boolean requiresResponse
-
message
protected Message message
-
messageBodySize
protected long messageBodySize
to be sent on the last package
-
-
Constructor Detail
-
SessionSendContinuationMessage
public SessionSendContinuationMessage()
-
SessionSendContinuationMessage
protected SessionSendContinuationMessage(byte type)
-
SessionSendContinuationMessage
public SessionSendContinuationMessage(Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
- Parameters:
body-continues-requiresResponse-
-
SessionSendContinuationMessage
protected SessionSendContinuationMessage(byte type, Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)- Parameters:
body-continues-requiresResponse-
-
-
Method Detail
-
isRequiresResponse
public boolean isRequiresResponse()
- Specified by:
isRequiresResponsein interfacePacket- Overrides:
isRequiresResponsein classPacketImpl- Returns:
- the requiresResponse
-
getMessageBodySize
public long getMessageBodySize()
-
getMessage
public Message getMessage()
- Returns:
- the message
-
expectedEncodeSize
public int expectedEncodeSize()
Description copied from class:SessionContinuationMessageReturns the exact expected encoded size ofthispacket. It will be used to allocate the proper encoding buffer inPacketImpl.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 ofPacketImpl.createPacket(org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection). Any child ofthisclass are required to override this method if their encoded size is changed from the base class.- Specified by:
expectedEncodeSizein interfacePacket- Overrides:
expectedEncodeSizein classSessionContinuationMessage- Returns:
- the size in bytes of the expected encoded packet
-
encodeRest
public void encodeRest(ActiveMQBuffer buffer)
- Overrides:
encodeRestin classSessionContinuationMessage
-
decodeRest
public void decodeRest(ActiveMQBuffer buffer)
- Overrides:
decodeRestin classSessionContinuationMessage
-
hashCode
public int hashCode()
- Overrides:
hashCodein classSessionContinuationMessage
-
getPacketString
protected String getPacketString()
- Overrides:
getPacketStringin classSessionContinuationMessage
-
equals
public boolean equals(Object obj)
- Overrides:
equalsin classSessionContinuationMessage
-
getHandler
public SendAcknowledgementHandler getHandler()
-
-