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
-
Field Summary
Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionXAResponseMessage
error, message, responseCodeFields 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_V2Fields inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet
INITIAL_PACKET_SIZE -
Constructor Summary
ConstructorsConstructorDescriptionSessionXAResponseMessage_V2(long correlationID, boolean isError, int responseCode, String message) -
Method Summary
Modifier and TypeMethodDescriptionvoiddecodeRest(ActiveMQBuffer buffer) voidencodeRest(ActiveMQBuffer buffer) booleanlongprotected StringinthashCode()final booleanReturns true if this packet is being sent in response to a previously received packet.final booleanMethods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionXAResponseMessage
getMessage, getResponseCode, isErrorMethods 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, toStringMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods 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:
getCorrelationIDin interfacePacket- Overrides:
getCorrelationIDin classPacketImpl
-
encodeRest
- Overrides:
encodeRestin classSessionXAResponseMessage
-
decodeRest
- Overrides:
decodeRestin classSessionXAResponseMessage
-
isResponse
public final boolean isResponse()Description copied from interface:PacketReturns true if this packet is being sent in response to a previously received packet.- Specified by:
isResponsein interfacePacket- Overrides:
isResponsein classSessionXAResponseMessage- Returns:
- true if this packet is being sent in response to a previously received packet
-
isResponseAsync
public final boolean isResponseAsync()- Specified by:
isResponseAsyncin interfacePacket- Overrides:
isResponseAsyncin classPacketImpl
-
getPacketString
- Overrides:
getPacketStringin classSessionXAResponseMessage
-
hashCode
public int hashCode()- Overrides:
hashCodein classSessionXAResponseMessage
-
equals
- Overrides:
equalsin classSessionXAResponseMessage
-