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

Class SubscribeClusterTopologyUpdatesMessageV2

java.lang.Object

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

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

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

All Implemented Interfaces:

Packet

public class SubscribeClusterTopologyUpdatesMessageV2
extends SubscribeClusterTopologyUpdatesMessage

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, DISCONNECT_CONSUMER, 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
SubscribeClusterTopologyUpdatesMessageV2()
SubscribeClusterTopologyUpdatesMessageV2(boolean clusterConnection, int clientVersion)

Method Summary

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
boolean	equals(Object obj)
int	getClientVersion()
int	hashCode()

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

isClusterConnection, toString

Methods inherited from class org.hornetq.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

Constructor Detail

SubscribeClusterTopologyUpdatesMessageV2

public SubscribeClusterTopologyUpdatesMessageV2(boolean clusterConnection,
                                                int clientVersion)

SubscribeClusterTopologyUpdatesMessageV2

public SubscribeClusterTopologyUpdatesMessageV2()

Method Detail

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class SubscribeClusterTopologyUpdatesMessage

getClientVersion

public int getClientVersion()

Returns:

the clientVersion

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class SubscribeClusterTopologyUpdatesMessage

hashCode

public int hashCode()

Overrides:

hashCode in class SubscribeClusterTopologyUpdatesMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SubscribeClusterTopologyUpdatesMessage