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

Class SessionXAResponseMessage_V2

java.lang.Object

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

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

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

All Implemented Interfaces:

Packet

public class SessionXAResponseMessage_V2
extends SessionXAResponseMessage

Field Summary

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

error, message, responseCode

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

Constructor	Description
SessionXAResponseMessage_V2()
SessionXAResponseMessage_V2(long correlationID, boolean isError, int responseCode, String message)

Method Summary

Modifier and Type	Method	Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
long	getCorrelationID()
protected String	getPacketString()
int	hashCode()
final boolean	isResponse()	Returns true if this packet is being sent in response to a previously received packet.
final boolean	isResponseAsync()

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

getMessage, getResponseCode, isError

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

expectedEncodeSize, release

Constructor Details

SessionXAResponseMessage_V2

public SessionXAResponseMessage_V2(long correlationID,
 boolean isError,
 int responseCode,
 String message)

SessionXAResponseMessage_V2

public SessionXAResponseMessage_V2()

Method Details

getCorrelationID

public long getCorrelationID()

Specified by:

getCorrelationID in interface Packet

Overrides:

getCorrelationID in class PacketImpl

encodeRest

public void encodeRest(ActiveMQBuffer buffer)

Overrides:

encodeRest in class SessionXAResponseMessage

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest in class SessionXAResponseMessage

isResponse

public final boolean isResponse()

Description copied from interface: Packet

Returns true if this packet is being sent in response to a previously received packet.

Specified by:

isResponse in interface Packet

Overrides:

isResponse in class SessionXAResponseMessage

Returns:

true if this packet is being sent in response to a previously received packet

isResponseAsync

public final boolean isResponseAsync()

Specified by:

isResponseAsync in interface Packet

Overrides:

isResponseAsync in class PacketImpl

getPacketString

protected String getPacketString()

Overrides:

getPacketString in class SessionXAResponseMessage

hashCode

public int hashCode()

Overrides:

hashCode in class SessionXAResponseMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionXAResponseMessage