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

Class SessionReceiveContinuationMessage

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.SessionReceiveContinuationMessage

All Implemented Interfaces:

Packet

public class SessionReceiveContinuationMessage
extends SessionContinuationMessage

Field Summary

Fields

Modifier and Type	Field and Description
static int	SESSION_RECEIVE_CONTINUATION_BASE_SIZE

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
SessionReceiveContinuationMessage()
SessionReceiveContinuationMessage(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
SessionReceiveContinuationMessage(long consumerID, byte[] body, boolean continues, boolean requiresResponse, int packetSize)

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	getConsumerID()
int	getPacketSize() returns the size needed to encode this packet.
int	hashCode()
String	toString()

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, getParentString, getType, isRequiresConfirmations, isRequiresResponse, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID

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 Detail

SESSION_RECEIVE_CONTINUATION_BASE_SIZE

public static final int SESSION_RECEIVE_CONTINUATION_BASE_SIZE

See Also:

Constant Field Values

Constructor Detail

SessionReceiveContinuationMessage

public SessionReceiveContinuationMessage()

SessionReceiveContinuationMessage

public SessionReceiveContinuationMessage(long consumerID,
                                         byte[] body,
                                         boolean continues,
                                         boolean requiresResponse)

Parameters:

consumerID -

body -

continues -

requiresResponse -

SessionReceiveContinuationMessage

public SessionReceiveContinuationMessage(long consumerID,
                                         byte[] body,
                                         boolean continues,
                                         boolean requiresResponse,
                                         int packetSize)

Method Detail

getConsumerID

public long getConsumerID()

Returns:

the consumerID

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

getPacketSize

public int getPacketSize()

Description copied from interface: Packet

returns the size needed to encode this packet.

Specified by:

getPacketSize in interface Packet

Overrides:

getPacketSize in class PacketImpl

Returns:

The size of the entire packet including headers, and extra data

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionContinuationMessage

hashCode

public int hashCode()

Overrides:

hashCode in class SessionContinuationMessage

toString

public String toString()

Overrides:

toString in class SessionContinuationMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionContinuationMessage