public class NodeAnnounceMessage extends PacketImpl
Modifier and Type | Field and Description |
---|---|
protected boolean |
backup |
protected TransportConfiguration |
backupConnector |
protected String |
backupGroupName |
protected TransportConfiguration |
connector |
protected long |
currentEventID |
protected String |
nodeID |
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
INITIAL_PACKET_SIZE
Constructor and Description |
---|
NodeAnnounceMessage() |
NodeAnnounceMessage(byte nodeAnnounceMessage_V2) |
NodeAnnounceMessage(long currentEventID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
boolean backup,
TransportConfiguration tc,
TransportConfiguration backupConnector) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(ActiveMQBuffer buffer) |
void |
encodeRest(ActiveMQBuffer buffer) |
boolean |
equals(Object obj) |
TransportConfiguration |
getBackupConnector() |
String |
getBackupGroupName() |
TransportConfiguration |
getConnector() |
long |
getCurrentEventID() |
String |
getNodeID() |
String |
getScaleDownGroupName() |
int |
hashCode() |
boolean |
isBackup() |
String |
toString() |
convertName, copyMessageBuffer, createPacket, decode, encode, encodeHeader, encodeRest, encodeSize, getChannelID, getCorrelationID, getPacketSize, getParentString, getType, isRequiresConfirmations, isRequiresResponse, isResponse, isResponseAsync, nullableStringEncodeSize, setChannelID, setCorrelationID
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
expectedEncodeSize, release
protected String nodeID
protected String backupGroupName
protected boolean backup
protected long currentEventID
protected TransportConfiguration connector
protected TransportConfiguration backupConnector
public NodeAnnounceMessage(long currentEventID, String nodeID, String backupGroupName, String scaleDownGroupName, boolean backup, TransportConfiguration tc, TransportConfiguration backupConnector)
public NodeAnnounceMessage()
public NodeAnnounceMessage(byte nodeAnnounceMessage_V2)
public String getNodeID()
public String getBackupGroupName()
public boolean isBackup()
public TransportConfiguration getConnector()
public TransportConfiguration getBackupConnector()
public String getScaleDownGroupName()
public long getCurrentEventID()
public void encodeRest(ActiveMQBuffer buffer)
encodeRest
in class PacketImpl
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class PacketImpl
public String toString()
toString
in class PacketImpl
public int hashCode()
hashCode
in class PacketImpl
public boolean equals(Object obj)
equals
in class PacketImpl
Copyright © 2019 JBoss by Red Hat. All rights reserved.