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

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

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
int	getClientVersion()

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, equals, getChannelID, getPacketSize, getParentString, getType, isAsyncExec, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, stringEncodeSize

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, 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