org.fjank.jcache.distribution
Class JGroupsDistributionEngine

java.lang.Object
  org.fjank.jcache.distribution.DistributionEngine
      org.fjank.jcache.distribution.JGroupsDistributionEngine

All Implemented Interfaces:

org.jgroups.MembershipListener, org.jgroups.MessageListener

public class JGroupsDistributionEngine
extends DistributionEngine
implements org.jgroups.MessageListener, org.jgroups.MembershipListener

Field Summary

Fields inherited from class org.fjank.jcache.distribution.DistributionEngine

cache

Method Summary

void	block()
Enumeration	getCacheAddr()
protected org.jgroups.JChannel	getChannel()
byte[]	getState() state not currently in use.
static JGroupsDistributionEngine	instanceOf(CacheImpl cache)
void	receive(org.jgroups.Message msg)
void	sendNotification(ClusterNotification clusterNotification)
void	setState(byte[] state) state not currently in use.
void	suspect(org.jgroups.Address suspected_mbr)
void	viewAccepted(org.jgroups.View new_view) Is called when new members arrives or leaves the group.

Methods inherited from class org.fjank.jcache.distribution.DistributionEngine

cacheObjectAdded, cacheObjectInvalidated, cacheObjectUpdated, getInstance, handleClusterNotification

Methods inherited from class java.lang.Object

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

Method Detail

instanceOf

public static JGroupsDistributionEngine instanceOf(CacheImpl cache)

block

public void block()

Specified by:

block in interface org.jgroups.MembershipListener

getCacheAddr

public Enumeration getCacheAddr()

Specified by:

getCacheAddr in class DistributionEngine

getChannel

protected org.jgroups.JChannel getChannel()

getState

public byte[] getState()

state not currently in use.

Specified by:

getState in interface org.jgroups.MessageListener

receive

public void receive(org.jgroups.Message msg)

Specified by:

receive in interface org.jgroups.MessageListener

sendNotification

public void sendNotification(ClusterNotification clusterNotification)

Specified by:

sendNotification in class DistributionEngine

setState

public void setState(byte[] state)

state not currently in use.

Specified by:

setState in interface org.jgroups.MessageListener

suspect

public void suspect(org.jgroups.Address suspected_mbr)

Specified by:

suspect in interface org.jgroups.MembershipListener

viewAccepted

public void viewAccepted(org.jgroups.View new_view)

Is called when new members arrives or leaves the group.

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

See Also:

MembershipListener.viewAccepted(org.jgroups.View)