de.xima.fc.cluster.impl.jgroup

Class JGroupsCluster

java.lang.Object

java.util.AbstractMap<K,V>

org.jgroups.blocks.ReplicatedHashMap<String,NodeModel>

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

All Implemented Interfaces:

ICluster, Closeable, Serializable, AutoCloseable, ConcurrentMap<String,NodeModel>, Map<String,NodeModel>, org.jgroups.blocks.ReplicatedMap<String,NodeModel>, org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

public class JGroupsCluster
extends org.jgroups.blocks.ReplicatedHashMap<String,NodeModel>
implements ICluster

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.blocks.ReplicatedHashMap

org.jgroups.blocks.ReplicatedHashMap.Notification<K,V>

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields inherited from class org.jgroups.blocks.ReplicatedHashMap

call_options, disp, log, map, methods

Constructor Summary

Constructors

Constructor and Description
JGroupsCluster(org.jgroups.JChannel chan, JGroupsClusterConnection clusterConnection)

Method Summary

Modifier and Type	Method and Description
void	changeLocaleNodeState(ENodeState state)
void	close()
void	disconnect()
String	getID()
NodeModel	getLocaleNode()
String[]	getNodeIDs()
List<NodeModel>	getNodeList()
void	receive(org.jgroups.Message message)
void	sendMessage(IClusterMessage msg)
void	start()
void	suspect(org.jgroups.Address member)
void	viewAccepted(org.jgroups.View view)

Methods inherited from class org.jgroups.blocks.ReplicatedHashMap

_clear, _put, _putAll, _putIfAbsent, _remove, _remove, _replace, _replace, addNotifier, block, clear, containsKey, containsValue, entrySet, get, getChannel, getClusterName, getLocalAddress, getState, getTimeout, init, isBlockingUpdates, keySet, put, putAll, putIfAbsent, remove, remove, removeNotifier, replace, replace, setBlockingUpdates, setState, setTimeout, size, start, stop, synchronizedMap, unblock, values

Methods inherited from class java.util.AbstractMap

clone, equals, hashCode, isEmpty, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.ConcurrentMap

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, replaceAll

Methods inherited from interface java.util.Map

equals, hashCode, isEmpty

Constructor Detail

JGroupsCluster

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

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

receive

public void receive(org.jgroups.Message message)

Specified by:

receive in interface org.jgroups.MessageListener

Overrides:

receive in class org.jgroups.blocks.ReplicatedHashMap<String,NodeModel>

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

Overrides:

viewAccepted in class org.jgroups.blocks.ReplicatedHashMap<String,NodeModel>

suspect

public void suspect(org.jgroups.Address member)

Specified by:

suspect in interface org.jgroups.MembershipListener

Overrides:

suspect in class org.jgroups.blocks.ReplicatedHashMap<String,NodeModel>

getID

public String getID()

Specified by:

getID in interface ICluster

getNodeList

public List<NodeModel> getNodeList()

Specified by:

getNodeList in interface ICluster

getNodeIDs

public String[] getNodeIDs()

Specified by:

getNodeIDs in interface ICluster

getLocaleNode

public NodeModel getLocaleNode()

Specified by:

getLocaleNode in interface ICluster

disconnect

public void disconnect()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.jgroups.blocks.ReplicatedHashMap<String,NodeModel>

sendMessage

public void sendMessage(IClusterMessage msg)
                 throws Exception

Specified by:

sendMessage in interface ICluster

Throws:

Exception

changeLocaleNodeState

public void changeLocaleNodeState(ENodeState state)

Specified by:

changeLocaleNodeState in interface ICluster