org.hornetq.core.server.cluster

Interface ClusterConnection

All Superinterfaces:

ClusterTopologyListener, HornetQComponent

All Known Implementing Classes:

ClusterConnectionImpl

public interface ClusterConnection
extends HornetQComponent, ClusterTopologyListener

A ClusterConnection

Author:

Tim Fox Created 23 Jan 2009 14:51:55

Method Summary

Methods

Modifier and Type	Method and Description
void	activate()
void	addClusterTopologyListener(ClusterTopologyListener listener)
void	announceBackup()
String	describe()
void	flushExecutor()
TransportConfiguration	getConnector()
SimpleString	getName()
String	getNodeID()
Map<String,String>	getNodes()
HornetQServer	getServer()
Topology	getTopology()
void	informTopology()
boolean	isNodeActive(String id)
void	nodeAnnounced(long eventUID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)
void	removeClusterTopologyListener(ClusterTopologyListener listener)

Methods inherited from interface org.hornetq.core.server.HornetQComponent

isStarted, start, stop

Methods inherited from interface org.hornetq.api.core.client.ClusterTopologyListener

nodeDown, nodeUP

Method Detail

getName

SimpleString getName()

getNodeID

String getNodeID()

getServer

HornetQServer getServer()

nodeAnnounced

void nodeAnnounced(long eventUID,
                 String nodeID,
                 Pair<TransportConfiguration,TransportConfiguration> connectorPair,
                 boolean backup)

addClusterTopologyListener

void addClusterTopologyListener(ClusterTopologyListener listener)

removeClusterTopologyListener

void removeClusterTopologyListener(ClusterTopologyListener listener)

getNodes

Map<String,String> getNodes()

Returns:

a Map of node ID and addresses

activate

void activate()
              throws Exception

Throws:

Exception

getConnector

TransportConfiguration getConnector()

getTopology

Topology getTopology()

flushExecutor

void flushExecutor()

describe

String describe()

informTopology

void informTopology()

announceBackup

void announceBackup()

isNodeActive

boolean isNodeActive(String id)