Package net.ontopia.persistence.proxy.jgroups

Class JGroupsCluster

java.lang.Object

net.ontopia.persistence.proxy.jgroups.JGroupsCluster

All Implemented Interfaces:

ClusterIF, InstrumentedClusterIF, org.jgroups.Receiver

public class JGroupsCluster
extends Object
implements InstrumentedClusterIF, org.jgroups.Receiver

INTERNAL: Class that represents a jgroups cluster of Ontopia instances.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	JGroupsCluster.WrappedReceiver

Field Summary

Fields

Modifier and Type	Field	Description
protected org.jgroups.JChannel	channel
protected String	clusterId
protected final Set<ClusterNodeListenerIF>	listeners
protected ConcurrentLinkedQueue<JGroupsEvent>	queue
protected StorageIF	storage

Fields inherited from interface net.ontopia.persistence.proxy.ClusterIF

DATA_CACHE_CLEAR, DATA_CACHE_FIELD_EVICT, DATA_CACHE_FIELDS_EVICT, DATA_CACHE_IDENTITY_EVICT, QUERY_CACHE_RT1_CLEAR, QUERY_CACHE_RT1_EVICT, QUERY_CACHE_RT2_CLEAR, QUERY_CACHE_RT2_EVICT, QUERY_CACHE_SRCLOC_CLEAR, QUERY_CACHE_SRCLOC_EVICT, QUERY_CACHE_SUBIND_CLEAR, QUERY_CACHE_SUBIND_EVICT, QUERY_CACHE_SUBLOC_CLEAR, QUERY_CACHE_SUBLOC_EVICT

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JGroupsCluster(String clusterId, StorageIF storage)
	JGroupsCluster(String clusterId, org.jgroups.JChannel channel)

Method Summary

Modifier and Type	Method	Description
void	addClusterNodeListener(ClusterNodeListenerIF listener)
void	clearCache(IdentityIF namespace, int cacheType)
void	clearDatacache()
protected org.jgroups.JChannel	createChannel()
void	evictCache(IdentityIF namespace, int cacheType, Object key)
void	evictCache(IdentityIF namespace, int cacheType, Collection keys)
void	evictField(IdentityIF identity, int field)
void	evictFields(IdentityIF identity)
void	evictIdentity(IdentityIF identity)
void	flush()
org.jgroups.JChannel	getChannel()
String	getClusterName()
String	getClusterNode()
long	getClusterNodeCount()
Set<String>	getClusterNodes()
long	getClusterReceivedBytes()
long	getClusterReceivedMessages()
long	getClusterSentBytes()
long	getClusterSentMessages()
String	getClusterState()
protected long	getStat(ToLongFunction<org.jgroups.protocols.MsgStats> statMethod)
void	join()
void	leave()
protected void	processEvent(JGroupsEvent e)
void	receive(org.jgroups.Message msg)
void	removeClusterNodeListener(ClusterNodeListenerIF listener)
void	viewAccepted(org.jgroups.View view)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.Receiver

getState, receive, setState

Field Details

channel

protected org.jgroups.JChannel channel

clusterId

protected String clusterId

storage

protected StorageIF storage

queue

protected ConcurrentLinkedQueue<JGroupsEvent> queue

listeners

protected final Set<ClusterNodeListenerIF> listeners

Constructor Details

JGroupsCluster

protected JGroupsCluster(String clusterId,
 StorageIF storage)

JGroupsCluster

public JGroupsCluster(String clusterId,
 org.jgroups.JChannel channel)

Method Details

join

public void join()

Specified by:

join in interface ClusterIF

createChannel

protected org.jgroups.JChannel createChannel()

getChannel

public org.jgroups.JChannel getChannel()

leave

public void leave()

Specified by:

leave in interface ClusterIF

evictIdentity

public void evictIdentity(IdentityIF identity)

Specified by:

evictIdentity in interface ClusterIF

evictFields

public void evictFields(IdentityIF identity)

Specified by:

evictFields in interface ClusterIF

evictField

public void evictField(IdentityIF identity,
 int field)

Specified by:

evictField in interface ClusterIF

clearDatacache

public void clearDatacache()

Specified by:

clearDatacache in interface ClusterIF

evictCache

public void evictCache(IdentityIF namespace,
 int cacheType,
 Object key)

Specified by:

evictCache in interface ClusterIF

evictCache

public void evictCache(IdentityIF namespace,
 int cacheType,
 Collection keys)

Specified by:

evictCache in interface ClusterIF

clearCache

public void clearCache(IdentityIF namespace,
 int cacheType)

Specified by:

clearCache in interface ClusterIF

flush

public void flush()

Specified by:

flush in interface ClusterIF

processEvent

protected void processEvent(JGroupsEvent e)

receive

public void receive(org.jgroups.Message msg)

Specified by:

receive in interface org.jgroups.Receiver

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.Receiver

getClusterName

public String getClusterName()

Specified by:

getClusterName in interface ClusterIF

getClusterState

public String getClusterState()

Specified by:

getClusterState in interface InstrumentedClusterIF

getStat

protected long getStat(ToLongFunction<org.jgroups.protocols.MsgStats> statMethod)

getClusterReceivedBytes

public long getClusterReceivedBytes()

Specified by:

getClusterReceivedBytes in interface InstrumentedClusterIF

getClusterReceivedMessages

public long getClusterReceivedMessages()

Specified by:

getClusterReceivedMessages in interface InstrumentedClusterIF

getClusterSentBytes

public long getClusterSentBytes()

Specified by:

getClusterSentBytes in interface InstrumentedClusterIF

getClusterSentMessages

public long getClusterSentMessages()

Specified by:

getClusterSentMessages in interface InstrumentedClusterIF

getClusterNodeCount

public long getClusterNodeCount()

Specified by:

getClusterNodeCount in interface ClusterIF

getClusterNodes

public Set<String> getClusterNodes()

Specified by:

getClusterNodes in interface ClusterIF

getClusterNode

public String getClusterNode()

Specified by:

getClusterNode in interface ClusterIF

addClusterNodeListener

public void addClusterNodeListener(ClusterNodeListenerIF listener)

Specified by:

addClusterNodeListener in interface ClusterIF

removeClusterNodeListener

public void removeClusterNodeListener(ClusterNodeListenerIF listener)

Specified by:

removeClusterNodeListener in interface ClusterIF