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

Class JGroupsCluster

java.lang.Object

de.xima.fc.cluster.impl.jgroup.JGroupsCluster

All Implemented Interfaces:

ICluster, Serializable

public class JGroupsCluster
extends Object
implements ICluster

Implementation of a ICluster that uses EClusterImplementation.JGROUPS.

Since:

3.1.0

Author:

XIMA MEDIA GmbH

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
JGroupsCluster(org.jgroups.JChannel channel, JGroupsClusterConnection clusterConnection)	Creates a new JGroups cluster implementation.

Method Summary

Modifier and Type	Method	Description
void	changeLocaleNodeState(ENodeState state)	Changes the state of the local node, i.e. the node that corresponds to the server running this code.
<K extends Serializable,V extends Serializable> Map<K,V>	createReplicatedMap(@NotNull ReplicatedMapConfig mapConfig)
String	getID()
NodeModel	getLocaleNode()
String[]	getNodeIDs()
List<NodeModel>	getNodeList()
void	sendMessage(IClusterMessage msg)	Attempts to send a message to other nodes in the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupsCluster

public JGroupsCluster(org.jgroups.JChannel channel,
                      JGroupsClusterConnection clusterConnection)

Creates a new JGroups cluster implementation.

Parameters:

channel - Channel to use for the local node.

Method Detail

getID

public String getID()

Specified by:

getID in interface ICluster

Returns:

The ID of the entire cluster.

getNodeList

public List<NodeModel> getNodeList()

Specified by:

getNodeList in interface ICluster

Returns:

All nodes that are part of the cluster, whether they are currently connected.

getNodeIDs

public String[] getNodeIDs()

Specified by:

getNodeIDs in interface ICluster

Returns:

A list of the IDs of all nodes that are part of the cluster, whether they are currently connected.

sendMessage

public void sendMessage(IClusterMessage msg)
                 throws Exception

Description copied from interface: ICluster

Attempts to send a message to other nodes in the cluster.

Specified by:

sendMessage in interface ICluster

Parameters:

msg - Message to send to other nodes.

Throws:

Exception - When the message could not be sent, such as due to network failures.

createReplicatedMap

public <K extends Serializable,V extends Serializable> Map<K,V> createReplicatedMap(@NotNull
                                                                                                @NotNull ReplicatedMapConfig mapConfig)
                                                                                         throws Exception

Specified by:

createReplicatedMap in interface ICluster

Throws:

Exception

getLocaleNode

public NodeModel getLocaleNode()

Specified by:

getLocaleNode in interface ICluster

Returns:

The local node, i.e. the node that corresponds to the server running this code.

changeLocaleNodeState

public void changeLocaleNodeState(ENodeState state)

Description copied from interface: ICluster

Changes the state of the local node, i.e. the node that corresponds to the server running this code.

Specified by:

changeLocaleNodeState in interface ICluster

Parameters:

state - The new state for the node.