Class ClusterTopologyChangeMessage_V2
java.lang.Object
org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage_V2
- All Implemented Interfaces:
Packet
- Direct Known Subclasses:
ClusterTopologyChangeMessage_V3
-
Field Summary
FieldsFields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage
exit, last, nodeID, pairFields 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
ConstructorsConstructorDescriptionClusterTopologyChangeMessage_V2(byte clusterTopologyV3) ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID) ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID, String backupGroupName, Pair<TransportConfiguration, TransportConfiguration> pair, boolean last) -
Method Summary
Modifier and TypeMethodDescriptionvoiddecodeRest(ActiveMQBuffer buffer) voidencodeRest(ActiveMQBuffer buffer) booleanprotected StringlonginthashCode()Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage
getNodeID, getPair, isExit, isLastMethods 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, isRequiresResponse, isResponse, isResponseAsync, 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
-
Field Details
-
uniqueEventID
protected long uniqueEventID -
backupGroupName
-
-
Constructor Details
-
ClusterTopologyChangeMessage_V2
public ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID, String backupGroupName, Pair<TransportConfiguration, TransportConfiguration> pair, boolean last) -
ClusterTopologyChangeMessage_V2
-
ClusterTopologyChangeMessage_V2
public ClusterTopologyChangeMessage_V2() -
ClusterTopologyChangeMessage_V2
public ClusterTopologyChangeMessage_V2(byte clusterTopologyV3)
-
-
Method Details
-
getUniqueEventID
public long getUniqueEventID() -
getBackupGroupName
-
encodeRest
- Overrides:
encodeRestin classClusterTopologyChangeMessage
-
decodeRest
- Overrides:
decodeRestin classClusterTopologyChangeMessage
-
hashCode
public int hashCode()- Overrides:
hashCodein classClusterTopologyChangeMessage
-
getPacketString
- Overrides:
getPacketStringin classClusterTopologyChangeMessage
-
equals
- Overrides:
equalsin classClusterTopologyChangeMessage
-