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

Class ClusterTopologyChangeMessage

java.lang.Object

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

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

All Implemented Interfaces:

Packet

Direct Known Subclasses:

ClusterTopologyChangeMessage_V2

public class ClusterTopologyChangeMessage
extends PacketImpl

Author:

Tim Fox

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	exit
protected boolean	last
protected String	nodeID
protected Pair<TransportConfiguration,TransportConfiguration>	pair

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

channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_QUEUE, CREATE_REPLICATION, 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_COMPARE_DATA, 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_SYNC, 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_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_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, type

Constructor Summary

Constructors

Constructor and Description
ClusterTopologyChangeMessage()
ClusterTopologyChangeMessage(byte clusterTopologyV2)
ClusterTopologyChangeMessage(String nodeID)
ClusterTopologyChangeMessage(String nodeID, Pair<TransportConfiguration,TransportConfiguration> pair, boolean last)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
String	getNodeID()
Pair<TransportConfiguration,TransportConfiguration>	getPair()
boolean	isExit()
boolean	isLast()

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

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

Methods inherited from class java.lang.Object

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

Field Detail

exit

protected boolean exit

nodeID

protected String nodeID

pair

protected Pair<TransportConfiguration,TransportConfiguration> pair

last

protected boolean last

Constructor Detail

ClusterTopologyChangeMessage

public ClusterTopologyChangeMessage(String nodeID,
                            Pair<TransportConfiguration,TransportConfiguration> pair,
                            boolean last)

ClusterTopologyChangeMessage

public ClusterTopologyChangeMessage(String nodeID)

ClusterTopologyChangeMessage

public ClusterTopologyChangeMessage()

ClusterTopologyChangeMessage

public ClusterTopologyChangeMessage(byte clusterTopologyV2)

Parameters:

clusterTopologyV2 -

Method Detail

getNodeID

public String getNodeID()

getPair

public Pair<TransportConfiguration,TransportConfiguration> getPair()

isLast

public boolean isLast()

isExit

public boolean isExit()

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class PacketImpl