Package de.xima.fc.cluster.impl.jgroup

Class JGroupsClusterConnection

java.lang.Object

de.xima.fc.cluster.impl.jgroup.JGroupsClusterConnection

All Implemented Interfaces:

IClusterConnection, Closeable, Serializable, AutoCloseable

public class JGroupsClusterConnection
extends Object
implements IClusterConnection, Serializable

Implementation of a IClusterConnection that uses EClusterImplementation.JGROUPS.

Author:

XIMA MEDIA GmbH

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
JGroupsClusterConnection()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the connection to other nodes.
static IClusterConnection	create()	Methode zum Erstellen einer JGroups-basierten IClusterConnection-Implementierung
void	disconnect()	Disconnects the node from the cluster.
IClusterChannelStateObserver	getChannelObserver()
ICluster	getCluster()
String	getClusterName()
IClusterMessageObserver	getMessageObserver()
String	getNodeName()
IClusterTopologyObserver	getTopologyObserver()
void	open()	Opens this connection.

Methods inherited from class java.lang.Object

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

Constructor Details

JGroupsClusterConnection

public JGroupsClusterConnection()

Method Details

create

public static IClusterConnection create()

Methode zum Erstellen einer JGroups-basierten IClusterConnection-Implementierung

Returns:

an IClusterConnection

open

public void open()
          throws ClusterOpenException

Description copied from interface: IClusterConnection

Opens this connection. When no node exists yet, a new group is created. Otherwise, when a group exists already, joins that groups.

Specified by:

open in interface IClusterConnection

Throws:

ClusterOpenException - When the connection could not be opened, such as due to a network failure etc.

close

public void close()

Description copied from interface: IClusterConnection

Closes the connection to other nodes. This method closes the entire cluster, so that no more nodes can be added to the group.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface IClusterConnection

disconnect

public void disconnect()

Description copied from interface: IClusterConnection

Disconnects the node from the cluster. The node can join the cluster again later by calling IClusterConnection.open().

Specified by:

disconnect in interface IClusterConnection

getTopologyObserver

public IClusterTopologyObserver getTopologyObserver()

Specified by:

getTopologyObserver in interface IClusterConnection

Returns:

The observer that can be used to listen for changes to the cluster topology (e.g. when a node is added or removed from the cluster).

getChannelObserver

public IClusterChannelStateObserver getChannelObserver()

Specified by:

getChannelObserver in interface IClusterConnection

Returns:

The observer that can be used to listen for changes to the channel state, e.g. when the connection to a node was established or cut, or the channel was closed.

getMessageObserver

public IClusterMessageObserver getMessageObserver()

Specified by:

getMessageObserver in interface IClusterConnection

Returns:

The observer that can be used to listen for messages sent between nodes.

getClusterName

public String getClusterName()

Returns:

The name of this cluster.

getNodeName

public String getNodeName()

Returns:

The name of the local node, i.e. the node corresponding to the server running this code.

getCluster

public ICluster getCluster()

Specified by:

getCluster in interface IClusterConnection

Returns:

The cluster to