org.hornetq.core.protocol.core.impl.wireformat

Class NodeAnnounceMessage

java.lang.Object

org.hornetq.core.protocol.core.impl.PacketImpl

org.hornetq.core.protocol.core.impl.wireformat.NodeAnnounceMessage

All Implemented Interfaces:

Packet

public class NodeAnnounceMessage
extends PacketImpl

Author:

Tim Fox

Field Summary

Fields inherited from class org.hornetq.core.protocol.core.impl.PacketImpl

BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_QUEUE, CREATE_SHARED_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, 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_SCHEDULED_FAILOVER, REPLICATION_START_FINISH_SYNC, REPLICATION_SYNC_FILE, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, 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_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(long currentEventID, String nodeID, String nodeName, boolean backup, TransportConfiguration tc, TransportConfiguration backupConnector)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
boolean	equals(Object obj)
TransportConfiguration	getBackupConnector()
TransportConfiguration	getConnector()
long	getCurrentEventID()
String	getNodeID()
String	getNodeName()
int	hashCode()
boolean	isBackup()
String	toString()

Methods inherited from class org.hornetq.core.protocol.core.impl.PacketImpl

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeAnnounceMessage

public NodeAnnounceMessage(long currentEventID,
                   String nodeID,
                   String nodeName,
                   boolean backup,
                   TransportConfiguration tc,
                   TransportConfiguration backupConnector)

NodeAnnounceMessage

public NodeAnnounceMessage()

Method Detail

getNodeID

public String getNodeID()

getNodeName

public String getNodeName()

isBackup

public boolean isBackup()

getConnector

public TransportConfiguration getConnector()

getBackupConnector

public TransportConfiguration getBackupConnector()

getCurrentEventID

public long getCurrentEventID()

Returns:

the currentEventID

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class PacketImpl

toString

public String toString()

Overrides:

toString in class PacketImpl

hashCode

public int hashCode()

Overrides:

hashCode in class PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl