|
ehcache | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object net.sf.ehcache.distribution.RMISynchronousCacheReplicator net.sf.ehcache.distribution.RMIAsynchronousCacheReplicator
public class RMIAsynchronousCacheReplicator
Listens to CacheManager
and Cache
events and propagates those to
CachePeer
peers of the Cache asynchronously.
RMISynchronousCacheReplicator
, it does suffer from a number
of problems. Elements, which may be being spooled to DiskStore may stay around in memory because references
are being held to them from EventMessage
s which are queued up. The replication thread runs once
per second, limiting the build up. However a lot of elements can be put into a cache in that time. We do not want
to get an OutOfMemoryError
using distribution in circumstances when it would not happen if we were
just using the DiskStore.
Accordingly, the Element values in EventMessage
s are held by SoftReference
in the queue,
so that they can be discarded if required by the GC to avoid an OutOfMemoryError
. A log message
will be issued on each flush of the queue if there were any forced discards. One problem with GC collection
of SoftReferences is that the VM (JDK1.5 anyway) will do that rather than grow the heap size to the maximum.
The workaround is to either set minimum heap size to the maximum heap size to force heap allocation at start
up, or put up with a few lost messages while the heap grows.
Field Summary |
---|
Fields inherited from class net.sf.ehcache.distribution.RMISynchronousCacheReplicator |
---|
replicatePuts, replicatePutsViaCopy, replicateRemovals, replicateUpdates, replicateUpdatesViaCopy, status |
Constructor Summary | |
---|---|
RMIAsynchronousCacheReplicator(boolean replicatePuts,
boolean replicatePutsViaCopy,
boolean replicateUpdates,
boolean replicateUpdatesViaCopy,
boolean replicateRemovals,
int replicationInterval,
int maximumBatchSize)
Constructor for internal and subclass use |
Method Summary | |
---|---|
protected void |
addToReplicationQueue(RmiEventMessage eventMessage)
Adds a message to the queue. |
Object |
clone()
Creates a clone of this listener. |
void |
dispose()
Give the replicator a chance to flush the replication queue, then cleanup and free resources when no longer needed |
void |
notifyElementPut(Ehcache cache,
Element element)
Called immediately after an element has been put into the cache. |
void |
notifyElementRemoved(Ehcache cache,
Element element)
Called immediately after an attempt to remove an element. |
void |
notifyElementUpdated(Ehcache cache,
Element element)
Called immediately after an element has been put into the cache and the element already existed in the cache. |
void |
notifyRemoveAll(Ehcache cache)
Called during Ehcache.removeAll() to indicate that the all
elements have been removed from the cache in a bulk operation. |
Methods inherited from class net.sf.ehcache.distribution.RMISynchronousCacheReplicator |
---|
alive, isReplicateUpdatesViaCopy, notAlive, notifyElementEvicted, notifyElementExpired, replicatePutNotification, replicateRemovalNotification, replicateRemoveAllNotification |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RMIAsynchronousCacheReplicator(boolean replicatePuts, boolean replicatePutsViaCopy, boolean replicateUpdates, boolean replicateUpdatesViaCopy, boolean replicateRemovals, int replicationInterval, int maximumBatchSize)
Method Detail |
---|
public final void notifyElementPut(Ehcache cache, Element element) throws CacheException
Cache.put(net.sf.ehcache.Element)
method
will block until this method returns.
Implementers may wish to have access to the Element's fields, including value, so the element is provided.
Implementers should be careful not to modify the element. The effect of any modifications is undefined.
This implementation queues the put notification for in-order replication to peers.
notifyElementPut
in interface CacheEventListener
notifyElementPut
in class RMISynchronousCacheReplicator
cache
- the cache emitting the notificationelement
- the element which was just put into the cache.
CacheException
public final void notifyElementUpdated(Ehcache cache, Element element) throws CacheException
Cache.put(net.sf.ehcache.Element)
method
will block until this method returns.
Implementers may wish to have access to the Element's fields, including value, so the element is provided.
Implementers should be careful not to modify the element. The effect of any modifications is undefined.
notifyElementUpdated
in interface CacheEventListener
notifyElementUpdated
in class RMISynchronousCacheReplicator
cache
- the cache emitting the notificationelement
- the element which was just put into the cache.
CacheException
public final void notifyElementRemoved(Ehcache cache, Element element) throws CacheException
notifyElementRemoved
in interface CacheEventListener
notifyElementRemoved
in class RMISynchronousCacheReplicator
cache
- the cache emitting the notificationelement
- the element just deleted, or a synthetic element with just the key set if
no element was removed.
CacheException
public void notifyRemoveAll(Ehcache cache)
Ehcache.removeAll()
to indicate that the all
elements have been removed from the cache in a bulk operation. The usual
notifyElementRemoved(net.sf.ehcache.Ehcache,net.sf.ehcache.Element)
is not called.
This notification exists because clearing a cache is a special case. It is often
not practical to serially process notifications where potentially millions of elements
have been bulk deleted.
notifyRemoveAll
in interface CacheEventListener
notifyRemoveAll
in class RMISynchronousCacheReplicator
cache
- the cache emitting the notificationprotected void addToReplicationQueue(RmiEventMessage eventMessage)
cacheEventMessage
- public final void dispose()
dispose
in interface CacheEventListener
dispose
in class RMISynchronousCacheReplicator
public Object clone() throws CloneNotSupportedException
clone
in interface CacheEventListener
clone
in class RMISynchronousCacheReplicator
CloneNotSupportedException
- if the listener could not be cloned.
|
ehcache | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |