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

Class NodeAnnounceMessage

java.lang.Object

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

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

All Implemented Interfaces:

org.apache.activemq.artemis.core.protocol.core.Packet

public class NodeAnnounceMessage
extends org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	backup
protected org.apache.activemq.artemis.api.core.TransportConfiguration	backupConnector
protected String	backupGroupName
protected org.apache.activemq.artemis.api.core.TransportConfiguration	connector
protected long	currentEventID
protected String	nodeID

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

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, CREATE_QUEUE, CREATE_SHARED_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, 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_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_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

Constructor Summary

Constructors

Constructor and Description
NodeAnnounceMessage()
NodeAnnounceMessage(byte nodeAnnounceMessage_V2)
NodeAnnounceMessage(long currentEventID, String nodeID, String backupGroupName, String scaleDownGroupName, boolean backup, org.apache.activemq.artemis.api.core.TransportConfiguration tc, org.apache.activemq.artemis.api.core.TransportConfiguration backupConnector)

Method Summary

Modifier and Type	Method and Description
void	decodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
void	encodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
boolean	equals(Object obj)
org.apache.activemq.artemis.api.core.TransportConfiguration	getBackupConnector()
String	getBackupGroupName()
org.apache.activemq.artemis.api.core.TransportConfiguration	getConnector()
long	getCurrentEventID()
String	getNodeID()
String	getScaleDownGroupName()
int	hashCode()
boolean	isBackup()
String	toString()

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

decode, encode, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

nodeID

protected String nodeID

backupGroupName

protected String backupGroupName

backup

protected boolean backup

currentEventID

protected long currentEventID

connector

protected org.apache.activemq.artemis.api.core.TransportConfiguration connector

backupConnector

protected org.apache.activemq.artemis.api.core.TransportConfiguration backupConnector

Constructor Detail

NodeAnnounceMessage

public NodeAnnounceMessage(long currentEventID,
                           String nodeID,
                           String backupGroupName,
                           String scaleDownGroupName,
                           boolean backup,
                           org.apache.activemq.artemis.api.core.TransportConfiguration tc,
                           org.apache.activemq.artemis.api.core.TransportConfiguration backupConnector)

NodeAnnounceMessage

public NodeAnnounceMessage()

NodeAnnounceMessage

public NodeAnnounceMessage(byte nodeAnnounceMessage_V2)

Method Detail

getNodeID

public String getNodeID()

getBackupGroupName

public String getBackupGroupName()

isBackup

public boolean isBackup()

getConnector

public org.apache.activemq.artemis.api.core.TransportConfiguration getConnector()

getBackupConnector

public org.apache.activemq.artemis.api.core.TransportConfiguration getBackupConnector()

getScaleDownGroupName

public String getScaleDownGroupName()

getCurrentEventID

public long getCurrentEventID()

Returns:

the currentEventID

encodeRest

public void encodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

Overrides:

encodeRest in class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

decodeRest

public void decodeRest(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

Overrides:

decodeRest in class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

toString

public String toString()

Overrides:

toString in class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

hashCode

public int hashCode()

Overrides:

hashCode in class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl