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

Class SessionContinuationMessage

java.lang.Object

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

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

All Implemented Interfaces:

Packet

Direct Known Subclasses:

SessionReceiveContinuationMessage, SessionSendContinuationMessage

public abstract class SessionContinuationMessage
extends PacketImpl

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	body
protected boolean	continues
static int	SESSION_CONTINUATION_BASE_SIZE

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

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, CREATE_QUEUE, CREATE_SHARED_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, 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_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_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
SessionContinuationMessage(byte type)
SessionContinuationMessage(byte type, byte[] body, boolean continues)

Method Summary

Modifier and Type	Method and Description
void	decodeRest(ActiveMQBuffer buffer)
ActiveMQBuffer	encode(RemotingConnection connection) Encodes the packet and returns a ActiveMQBuffer containing the data
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
int	expectedEncodeSize() Returns the exact expected encoded size of this packet.
byte[]	getBody()
int	hashCode()
boolean	isContinues()
String	toString()

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

createPacket, decode, 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

Field Detail

SESSION_CONTINUATION_BASE_SIZE

public static final int SESSION_CONTINUATION_BASE_SIZE

See Also:

Constant Field Values

body

protected byte[] body

continues

protected boolean continues

Constructor Detail

SessionContinuationMessage

public SessionContinuationMessage(byte type,
                                  byte[] body,
                                  boolean continues)

SessionContinuationMessage

public SessionContinuationMessage(byte type)

Method Detail

getBody

public byte[] getBody()

Returns:

the body

isContinues

public boolean isContinues()

Returns:

the continues

expectedEncodeSize

public int expectedEncodeSize()

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.spi.core.protocol.RemotingConnection), 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.spi.core.protocol.RemotingConnection). Any child of this class are required to override this method if their encoded size is changed from the base class.

Returns:

the size in bytes of the expected encoded packet

encode

public final ActiveMQBuffer encode(RemotingConnection connection)

Description copied from interface: Packet

Encodes the packet and returns a ActiveMQBuffer containing the data

Specified by:

encode in interface Packet

Overrides:

encode in class PacketImpl

Parameters:

connection - the connection

Returns:

the buffer to encode to

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class PacketImpl

hashCode

public int hashCode()

Overrides:

hashCode in class PacketImpl

toString

public String toString()

Overrides:

toString in class PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl