org.hornetq.core.protocol.core.impl.wireformat
public class ClusterTopologyChangeMessage_V2 extends ClusterTopologyChangeMessage
exit, last, nodeID, pair
BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_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 and Description |
---|
ClusterTopologyChangeMessage_V2() |
ClusterTopologyChangeMessage_V2(long uniqueEventID,
String nodeID) |
ClusterTopologyChangeMessage_V2(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(HornetQBuffer buffer) |
void |
encodeRest(HornetQBuffer buffer) |
boolean |
equals(Object obj) |
String |
getNodeName() |
long |
getUniqueEventID() |
int |
hashCode() |
getNodeID, getPair, isExit, isLast
decode, encode, getChannelID, getPacketSize, getParentString, getType, isAsyncExec, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, toString
public ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID, String nodeName, Pair<TransportConfiguration,TransportConfiguration> pair, boolean last)
public ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID)
public ClusterTopologyChangeMessage_V2()
public long getUniqueEventID()
public String getNodeName()
public void encodeRest(HornetQBuffer buffer)
encodeRest
in class ClusterTopologyChangeMessage
public void decodeRest(HornetQBuffer buffer)
decodeRest
in class ClusterTopologyChangeMessage
public int hashCode()
hashCode
in class ClusterTopologyChangeMessage
public boolean equals(Object obj)
equals
in class ClusterTopologyChangeMessage
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.