net.ontopia.persistence.proxy

Class JGroupsCluster

java.lang.Object

org.jgroups.ReceiverAdapter

net.ontopia.persistence.proxy.JGroupsCluster

All Implemented Interfaces:

ClusterIF, org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver, org.jgroups.StateListener

public class JGroupsCluster
extends org.jgroups.ReceiverAdapter
implements ClusterIF

INTERNAL: Class that represents a cluster of OKS instances.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clusterId
protected String	clusterProps
protected org.jgroups.JChannel	dchannel
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 and Description
protected	JGroupsCluster(String clusterId, String clusterProps, StorageIF storage)

Method Summary

Modifier and Type	Method and Description
void	clearCache(IdentityIF namespace, int cacheType)
void	clearDatacache()
void	evictCache(IdentityIF namespace, int cacheType, Collection keys)
void	evictCache(IdentityIF namespace, int cacheType, Object key)
void	evictField(IdentityIF identity, int field)
void	evictFields(IdentityIF identity)
void	evictIdentity(IdentityIF identity)
void	flush()
void	join()
void	leave()
protected void	processEvent(JGroupsEvent e)
void	receive(org.jgroups.Message msg)

Methods inherited from class org.jgroups.ReceiverAdapter

block, getState, receive, setState, suspect, unblock, viewAccepted

Methods inherited from class java.lang.Object

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

Field Detail

dchannel

protected org.jgroups.JChannel dchannel

clusterId

protected String clusterId

clusterProps

protected String clusterProps

storage

protected StorageIF storage

queue

protected ConcurrentLinkedQueue<JGroupsEvent> queue

Constructor Detail

JGroupsCluster

protected JGroupsCluster(String clusterId,
                         String clusterProps,
                         StorageIF storage)

Method Detail

join

public void join()

Specified by:

join in interface ClusterIF

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.MessageListener

Overrides:

receive in class org.jgroups.ReceiverAdapter