com.fr.ehcache.cluster.peer

类 JGroupsCacheReplicator

java.lang.Object

com.fr.ehcache.cluster.peer.JGroupsCacheReplicator

所有已实现的接口:

com.fr.third.net.sf.ehcache.distribution.CacheReplicator, com.fr.third.net.sf.ehcache.event.CacheEventListener, java.lang.Cloneable

public class JGroupsCacheReplicator
extends java.lang.Object
implements com.fr.third.net.sf.ehcache.distribution.CacheReplicator

通过CachePeer发送本机的复本消息到其它节点同步监听

版本:

$Id: JGroupsCacheReplicator.java 2679 2010-08-26 01:53:05Z gluck $

This implements CacheReplicator using JGroups as underlying replication mechanism The peer provider should be of type JGroupsCacheManagerPeerProvider It is assumed that the cachepeer is a JGroupsCacheManagerPeerProvider

作者:

Pierre Monestie (pmonestie[at]@gmail.com), Greg Luck

字段概要

字段

限定符和类型	字段和说明
static long	DEFAULT_ASYNC_INTERVAL The default interval for async cache replication

构造器概要

构造器

构造器和说明
JGroupsCacheReplicator(boolean replicatePuts, boolean replicateUpdates, boolean replicateUpdatesViaCopy, boolean replicateRemovals) Constructor called by factory, does synchronous replication
JGroupsCacheReplicator(boolean replicatePuts, boolean replicateUpdates, boolean replicateUpdatesViaCopy, boolean replicateRemovals, long asynchronousReplicationInterval) Constructor called by factory, does asynchronous replication

方法概要

方法

限定符和类型	方法和说明
boolean	alive()
java.lang.Object	clone()
void	dispose()
boolean	isReplicateUpdatesViaCopy()
boolean	notAlive()
void	notifyElementEvicted(com.fr.third.net.sf.ehcache.Ehcache cache, com.fr.third.net.sf.ehcache.Element element)
void	notifyElementExpired(com.fr.third.net.sf.ehcache.Ehcache cache, com.fr.third.net.sf.ehcache.Element element)
void	notifyElementPut(com.fr.third.net.sf.ehcache.Ehcache cache, com.fr.third.net.sf.ehcache.Element element)
void	notifyElementRemoved(com.fr.third.net.sf.ehcache.Ehcache cache, com.fr.third.net.sf.ehcache.Element element)
void	notifyElementUpdated(com.fr.third.net.sf.ehcache.Ehcache cache, com.fr.third.net.sf.ehcache.Element element)
void	notifyRemoveAll(com.fr.third.net.sf.ehcache.Ehcache cache)
protected void	sendNotification(com.fr.third.net.sf.ehcache.Ehcache cache, JGroupEventMessage eventMessage) Used to send notification to the peer.

从类继承的方法 java.lang.Object

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

字段详细资料

DEFAULT_ASYNC_INTERVAL

public static final long DEFAULT_ASYNC_INTERVAL

The default interval for async cache replication

另请参阅:

常量字段值

构造器详细资料

JGroupsCacheReplicator

public JGroupsCacheReplicator(boolean replicatePuts,
                      boolean replicateUpdates,
                      boolean replicateUpdatesViaCopy,
                      boolean replicateRemovals)

Constructor called by factory, does synchronous replication

JGroupsCacheReplicator

public JGroupsCacheReplicator(boolean replicatePuts,
                      boolean replicateUpdates,
                      boolean replicateUpdatesViaCopy,
                      boolean replicateRemovals,
                      long asynchronousReplicationInterval)

Constructor called by factory, does asynchronous replication

方法详细资料

alive

public boolean alive()

指定者:

alive 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheReplicator

isReplicateUpdatesViaCopy

public boolean isReplicateUpdatesViaCopy()

指定者:

isReplicateUpdatesViaCopy 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheReplicator

notAlive

public boolean notAlive()

指定者:

notAlive 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheReplicator

dispose

public void dispose()

指定者:

dispose 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

notifyElementExpired

public void notifyElementExpired(com.fr.third.net.sf.ehcache.Ehcache cache,
                        com.fr.third.net.sf.ehcache.Element element)

指定者:

notifyElementExpired 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

notifyElementPut

public void notifyElementPut(com.fr.third.net.sf.ehcache.Ehcache cache,
                    com.fr.third.net.sf.ehcache.Element element)
                      throws com.fr.third.net.sf.ehcache.CacheException

指定者:

notifyElementPut 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

抛出:

com.fr.third.net.sf.ehcache.CacheException

notifyElementRemoved

public void notifyElementRemoved(com.fr.third.net.sf.ehcache.Ehcache cache,
                        com.fr.third.net.sf.ehcache.Element element)
                          throws com.fr.third.net.sf.ehcache.CacheException

指定者:

notifyElementRemoved 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

抛出:

com.fr.third.net.sf.ehcache.CacheException

notifyElementUpdated

public void notifyElementUpdated(com.fr.third.net.sf.ehcache.Ehcache cache,
                        com.fr.third.net.sf.ehcache.Element element)
                          throws com.fr.third.net.sf.ehcache.CacheException

指定者:

notifyElementUpdated 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

抛出:

com.fr.third.net.sf.ehcache.CacheException

notifyElementEvicted

public void notifyElementEvicted(com.fr.third.net.sf.ehcache.Ehcache cache,
                        com.fr.third.net.sf.ehcache.Element element)

指定者:

notifyElementEvicted 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

notifyRemoveAll

public void notifyRemoveAll(com.fr.third.net.sf.ehcache.Ehcache cache)

指定者:

notifyRemoveAll 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

sendNotification

protected void sendNotification(com.fr.third.net.sf.ehcache.Ehcache cache,
                    JGroupEventMessage eventMessage)

Used to send notification to the peer. If Async this method simply add the element to the replication queue. If not async, searches for the cachePeer and send the Message. That way the class handles both async and sync replication Sending is delegated to the peer (of type JGroupsCacheManagerPeerProvider)

参数:

cache -

eventMessage -

clone

public java.lang.Object clone()
                       throws java.lang.CloneNotSupportedException

指定者:

clone 在接口中 com.fr.third.net.sf.ehcache.event.CacheEventListener

覆盖:

clone 在类中 java.lang.Object

抛出:

java.lang.CloneNotSupportedException