com.atlassian.jira.cluster.cache.ehcache

Class BlockingParallelCacheReplicator

java.lang.Object

com.atlassian.jira.cluster.cache.ehcache.AbstractJiraCacheReplicator

com.atlassian.jira.cluster.cache.ehcache.BlockingParallelCacheReplicator

All Implemented Interfaces:

Cloneable, net.sf.ehcache.distribution.CacheReplicator, net.sf.ehcache.event.CacheEventListener

public class BlockingParallelCacheReplicator
extends AbstractJiraCacheReplicator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockingParallelCacheReplicator.DeferredReplicationStrategy

Field Summary

Fields inherited from class com.atlassian.jira.cluster.cache.ehcache.AbstractJiraCacheReplicator

replicatePuts, replicatePutsViaCopy, replicateRemovals, replicateUpdates, replicateUpdatesViaCopy, replicationPauserManager

Method Summary

Modifier and Type	Method and Description
Object	clone()
protected void	replicatePutNotification(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
protected void	replicateRemovalNotification(net.sf.ehcache.Ehcache cache, Serializable key)
protected void	replicateRemoveAllNotification(net.sf.ehcache.Ehcache cache)
static <T> T	runDeferred(java.util.function.Supplier<T> supplier)

Methods inherited from class com.atlassian.jira.cluster.cache.ehcache.AbstractJiraCacheReplicator

alive, dispose, isReplicateUpdatesViaCopy, notAlive, notifyElementEvicted, notifyElementExpired, notifyElementPut, notifyElementRemoved, notifyElementUpdated, notifyRemoveAll

Methods inherited from class java.lang.Object

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

Method Detail

replicatePutNotification

protected void replicatePutNotification(net.sf.ehcache.Ehcache cache,
                                        net.sf.ehcache.Element element)
                                 throws net.sf.ehcache.distribution.RemoteCacheException

Specified by:

replicatePutNotification in class AbstractJiraCacheReplicator

Throws:

net.sf.ehcache.distribution.RemoteCacheException

replicateRemovalNotification

protected void replicateRemovalNotification(net.sf.ehcache.Ehcache cache,
                                            Serializable key)
                                     throws net.sf.ehcache.distribution.RemoteCacheException

Specified by:

replicateRemovalNotification in class AbstractJiraCacheReplicator

Throws:

net.sf.ehcache.distribution.RemoteCacheException

replicateRemoveAllNotification

protected void replicateRemoveAllNotification(net.sf.ehcache.Ehcache cache)

Specified by:

replicateRemoveAllNotification in class AbstractJiraCacheReplicator

clone

public Object clone()
             throws CloneNotSupportedException

Specified by:

clone in interface net.sf.ehcache.event.CacheEventListener

Specified by:

clone in class AbstractJiraCacheReplicator

Throws:

CloneNotSupportedException

runDeferred

public static <T> T runDeferred(java.util.function.Supplier<T> supplier)