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

Method Summary

Modifier and Type	Method and 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()
int	hashCode()
boolean	isRequiresResponse()
protected void	receiveMessage(io.netty.buffer.ByteBuf messageBuffer)
String	toString()

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

getMessage, getParentString, 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

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

requiresResponse

protected boolean requiresResponse

Constructor Detail

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 Detail

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

Returns:

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

toString

public String toString()

Overrides:

toString in class PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl