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

Class SessionSendMessage_V2

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

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

All Implemented Interfaces:

MessagePacketI, Packet

public class SessionSendMessage_V2
extends SessionSendMessage

Field Summary

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

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

Constructor and Description
SessionSendMessage_V2(CoreMessage message)
SessionSendMessage_V2(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)
protected int	fieldsEncodeSize()
long	getCorrelationID()
int	hashCode()
boolean	isResponseAsync()
void	setCorrelationID(long correlationID)
String	toString()

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

expectedEncodeSize, getHandler, isRequiresResponse, receiveMessage

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, getPacketSize, 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

Constructor Detail

SessionSendMessage_V2

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

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

SessionSendMessage_V2

public SessionSendMessage_V2(CoreMessage message)

Method Detail

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class SessionSendMessage

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionSendMessage

fieldsEncodeSize

protected int fieldsEncodeSize()

Overrides:

fieldsEncodeSize in class SessionSendMessage

getCorrelationID

public long getCorrelationID()

Specified by:

getCorrelationID in interface Packet

Overrides:

getCorrelationID in class PacketImpl

setCorrelationID

public void setCorrelationID(long correlationID)

Specified by:

setCorrelationID in interface Packet

Overrides:

setCorrelationID in class PacketImpl

isResponseAsync

public boolean isResponseAsync()

Specified by:

isResponseAsync in interface Packet

Overrides:

isResponseAsync in class PacketImpl

hashCode

public int hashCode()

Overrides:

hashCode in class SessionSendMessage

toString

public String toString()

Overrides:

toString in class SessionSendMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionSendMessage