org.hornetq.core.server.cluster.impl

Class ClusterConnectionImpl

java.lang.Object

org.hornetq.core.server.cluster.impl.ClusterConnectionImpl

All Implemented Interfaces:

ClusterTopologyListener, AfterConnectInternalListener, ClusterConnection, HornetQComponent

public class ClusterConnectionImpl
extends Object
implements ClusterConnection, AfterConnectInternalListener

A ClusterConnectionImpl

Author:

Tim Fox, Clebert Suconic Created 21 Jan 2009 14:43:05

Constructor Summary

Constructors

Constructor and Description
ClusterConnectionImpl(ClusterManagerImpl manager, DiscoveryGroupConfiguration dg, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, long callTimeout, boolean useDuplicateDetection, boolean routeWhenNoConsumers, int confirmationWindowSize, ExecutorFactory executorFactory, HornetQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, UUID nodeUUID, boolean backup, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly)
ClusterConnectionImpl(ClusterManagerInternal manager, TransportConfiguration[] tcConfigs, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, long callTimeout, boolean useDuplicateDetection, boolean routeWhenNoConsumers, int confirmationWindowSize, ExecutorFactory executorFactory, HornetQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, UUID nodeUUID, boolean backup, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly)

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()
Map<String,MessageFlowRecord>	getRecords()
HornetQServer	getServer()
Topology	getTopology()
void	informTopology()
boolean	isNodeActive(String nodeId)
boolean	isStarted()
void	nodeAnnounced(long uniqueEventID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)
void	nodeDown(long eventUID, String nodeID)
void	nodeUP(long eventUID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
void	onConnection(ClientSessionFactoryInternal sf)
void	removeClusterTopologyListener(ClusterTopologyListener listener)
void	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterConnectionImpl

public ClusterConnectionImpl(ClusterManagerInternal manager,
                     TransportConfiguration[] tcConfigs,
                     TransportConfiguration connector,
                     SimpleString name,
                     SimpleString address,
                     int minLargeMessageSize,
                     long clientFailureCheckPeriod,
                     long connectionTTL,
                     long retryInterval,
                     double retryIntervalMultiplier,
                     long maxRetryInterval,
                     int reconnectAttempts,
                     long callTimeout,
                     boolean useDuplicateDetection,
                     boolean routeWhenNoConsumers,
                     int confirmationWindowSize,
                     ExecutorFactory executorFactory,
                     HornetQServer server,
                     PostOffice postOffice,
                     ManagementService managementService,
                     ScheduledExecutorService scheduledExecutor,
                     int maxHops,
                     UUID nodeUUID,
                     boolean backup,
                     String clusterUser,
                     String clusterPassword,
                     boolean allowDirectConnectionsOnly)
                      throws Exception

Throws:

Exception

ClusterConnectionImpl

public ClusterConnectionImpl(ClusterManagerImpl manager,
                     DiscoveryGroupConfiguration dg,
                     TransportConfiguration connector,
                     SimpleString name,
                     SimpleString address,
                     int minLargeMessageSize,
                     long clientFailureCheckPeriod,
                     long connectionTTL,
                     long retryInterval,
                     double retryIntervalMultiplier,
                     long maxRetryInterval,
                     int reconnectAttempts,
                     long callTimeout,
                     boolean useDuplicateDetection,
                     boolean routeWhenNoConsumers,
                     int confirmationWindowSize,
                     ExecutorFactory executorFactory,
                     HornetQServer server,
                     PostOffice postOffice,
                     ManagementService managementService,
                     ScheduledExecutorService scheduledExecutor,
                     int maxHops,
                     UUID nodeUUID,
                     boolean backup,
                     String clusterUser,
                     String clusterPassword,
                     boolean allowDirectConnectionsOnly)
                      throws Exception

Throws:

Exception

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

flushExecutor

public void flushExecutor()

Specified by:

flushExecutor in interface ClusterConnection

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

announceBackup

public void announceBackup()

Specified by:

announceBackup in interface ClusterConnection

addClusterTopologyListener

public void addClusterTopologyListener(ClusterTopologyListener listener)

Specified by:

addClusterTopologyListener in interface ClusterConnection

removeClusterTopologyListener

public void removeClusterTopologyListener(ClusterTopologyListener listener)

Specified by:

removeClusterTopologyListener in interface ClusterConnection

getTopology

public Topology getTopology()

Specified by:

getTopology in interface ClusterConnection

nodeAnnounced

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

Specified by:

nodeAnnounced in interface ClusterConnection

onConnection

public void onConnection(ClientSessionFactoryInternal sf)

Specified by:

onConnection in interface AfterConnectInternalListener

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

getName

public SimpleString getName()

Specified by:

getName in interface ClusterConnection

getNodeID

public String getNodeID()

Specified by:

getNodeID in interface ClusterConnection

getServer

public HornetQServer getServer()

Specified by:

getServer in interface ClusterConnection

isNodeActive

public boolean isNodeActive(String nodeId)

Specified by:

isNodeActive in interface ClusterConnection

getNodes

public Map<String,String> getNodes()

Specified by:

getNodes in interface ClusterConnection

Returns:

a Map of node ID and addresses

activate

public void activate()
              throws Exception

Specified by:

activate in interface ClusterConnection

Throws:

Exception

getConnector

public TransportConfiguration getConnector()

Specified by:

getConnector in interface ClusterConnection

nodeDown

public void nodeDown(long eventUID,
            String nodeID)

Specified by:

nodeDown in interface ClusterTopologyListener

nodeUP

public void nodeUP(long eventUID,
          String nodeID,
          Pair<TransportConfiguration,TransportConfiguration> connectorPair,
          boolean last)

Specified by:

nodeUP in interface ClusterTopologyListener

informTopology

public void informTopology()

Specified by:

informTopology in interface ClusterConnection

getRecords

public Map<String,MessageFlowRecord> getRecords()

toString

public String toString()

Overrides:

toString in class Object

describe

public String describe()

Specified by:

describe in interface ClusterConnection