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

Class ClusterTopologyChangeMessage_V2

java.lang.Object

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

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

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

All Implemented Interfaces:

Packet

public class ClusterTopologyChangeMessage_V2
extends ClusterTopologyChangeMessage

Clebert Suconic

Field Summary

Fields inherited from class org.hornetq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage

exit, last, nodeID, pair

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
ClusterTopologyChangeMessage_V2()
ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID)
ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID, String nodeName, Pair<TransportConfiguration,TransportConfiguration> pair, boolean last)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
boolean	equals(Object obj)
String	getNodeName()
long	getUniqueEventID()
int	hashCode()

Methods inherited from class org.hornetq.core.protocol.core.impl.wireformat.ClusterTopologyChangeMessage

getNodeID, getPair, isExit, isLast

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterTopologyChangeMessage_V2

public ClusterTopologyChangeMessage_V2(long uniqueEventID,
                               String nodeID,
                               String nodeName,
                               Pair<TransportConfiguration,TransportConfiguration> pair,
                               boolean last)

ClusterTopologyChangeMessage_V2

public ClusterTopologyChangeMessage_V2(long uniqueEventID,
                               String nodeID)

ClusterTopologyChangeMessage_V2

public ClusterTopologyChangeMessage_V2()

Method Detail

getUniqueEventID

public long getUniqueEventID()

Returns:

the uniqueEventID

getNodeName

public String getNodeName()

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class ClusterTopologyChangeMessage

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class ClusterTopologyChangeMessage

hashCode

public int hashCode()

Overrides:

hashCode in class ClusterTopologyChangeMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class ClusterTopologyChangeMessage