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

Class SessionSendMessage

java.lang.Object

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

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

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

All Implemented Interfaces:

MessagePacketI, Packet

Direct Known Subclasses:

SessionSendMessage_1X, SessionSendMessage_V2

public class SessionSendMessage
extends MessagePacket

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	requiresResponse

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

message

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
protected	SessionSendMessage(byte id, ICoreMessage message, boolean requiresResponse, SendAcknowledgementHandler handler)	This will be using the CoreMessage because it is meant for the core-protocol
protected	SessionSendMessage(byte id, CoreMessage message)
	SessionSendMessage(ICoreMessage message, boolean requiresResponse, SendAcknowledgementHandler handler)	This will be using the CoreMessage because it is meant for the core-protocol
	SessionSendMessage(CoreMessage message)

Method Summary

Modifier and Type	Method	Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
int	expectedEncodeSize()	This will return the expected packet size for the encoding
protected int	fieldsEncodeSize()
SendAcknowledgementHandler	getHandler()
protected String	getPacketString()
int	getSenderID()
int	hashCode()
boolean	isRequiresResponse()
protected void	receiveMessage(io.netty.buffer.ByteBuf messageBuffer)

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

getMessage, replaceMessage

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

Constructor Details

SessionSendMessage

protected SessionSendMessage(byte id,
 ICoreMessage message,
 boolean requiresResponse,
 SendAcknowledgementHandler handler)

This will be using the CoreMessage because it is meant for the core-protocol

SessionSendMessage

protected SessionSendMessage(byte id,
 CoreMessage message)

SessionSendMessage

public SessionSendMessage(ICoreMessage message,
 boolean requiresResponse,
 SendAcknowledgementHandler handler)

This will be using the CoreMessage because it is meant for the core-protocol

SessionSendMessage

public SessionSendMessage(CoreMessage message)

Method Details

isRequiresResponse

public boolean isRequiresResponse()

Specified by:

isRequiresResponse in interface Packet

Overrides:

isRequiresResponse in class PacketImpl

getHandler

public SendAcknowledgementHandler getHandler()

expectedEncodeSize

public int expectedEncodeSize()

Description copied from interface: Packet

This will return the expected packet size for the encoding

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class PacketImpl

fieldsEncodeSize

protected int fieldsEncodeSize()

receiveMessage

protected void receiveMessage(io.netty.buffer.ByteBuf messageBuffer)

hashCode

public int hashCode()

Overrides:

hashCode in class PacketImpl

getPacketString

protected String getPacketString()

Overrides:

getPacketString in class MessagePacket

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl

getSenderID

public int getSenderID()