com.atlassian.jira.cluster.cache.ehcache

Class AbstractJiraCacheReplicator

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

LocalQCacheReplicator

public abstract class AbstractJiraCacheReplicator
extends Object
implements net.sf.ehcache.distribution.CacheReplicator

Basic cache replication code. History: this was extracted from BlockingParallelCacheReplicator.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	replicatePuts
protected boolean	replicatePutsViaCopy
protected boolean	replicateRemovals
protected boolean	replicateUpdates
protected boolean	replicateUpdatesViaCopy
protected java.util.function.Supplier<ReplicationPauserManager>	replicationPauserManager

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractJiraCacheReplicator(boolean replicatePuts, boolean replicatePutsViaCopy, boolean replicateUpdates, boolean replicateUpdatesViaCopy, boolean replicateRemovals, java.util.function.Supplier<ReplicationPauserManager> replicationPauserManager)

Method Summary

Modifier and Type	Method and Description
boolean	alive()
abstract Object	clone()
void	dispose()
boolean	isReplicateUpdatesViaCopy()
boolean	notAlive()
void	notifyElementEvicted(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementExpired(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementPut(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementRemoved(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementUpdated(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyRemoveAll(net.sf.ehcache.Ehcache cache)
protected abstract void	replicatePutNotification(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
protected abstract void	replicateRemovalNotification(net.sf.ehcache.Ehcache cache, Serializable key)
protected abstract void	replicateRemoveAllNotification(net.sf.ehcache.Ehcache cache)

Methods inherited from class java.lang.Object

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

Field Detail

replicatePuts

protected final boolean replicatePuts

replicatePutsViaCopy

protected final boolean replicatePutsViaCopy

replicateUpdates

protected final boolean replicateUpdates

replicateUpdatesViaCopy

protected final boolean replicateUpdatesViaCopy

replicateRemovals

protected final boolean replicateRemovals

replicationPauserManager

protected final java.util.function.Supplier<ReplicationPauserManager> replicationPauserManager

Constructor Detail

AbstractJiraCacheReplicator

protected AbstractJiraCacheReplicator(boolean replicatePuts,
                                      boolean replicatePutsViaCopy,
                                      boolean replicateUpdates,
                                      boolean replicateUpdatesViaCopy,
                                      boolean replicateRemovals,
                                      java.util.function.Supplier<ReplicationPauserManager> replicationPauserManager)

Method Detail

isReplicateUpdatesViaCopy

public boolean isReplicateUpdatesViaCopy()

Specified by:

isReplicateUpdatesViaCopy in interface net.sf.ehcache.distribution.CacheReplicator

notAlive

public boolean notAlive()

Specified by:

notAlive in interface net.sf.ehcache.distribution.CacheReplicator

alive

public boolean alive()

Specified by:

alive in interface net.sf.ehcache.distribution.CacheReplicator

notifyElementRemoved

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

Specified by:

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

Throws:

net.sf.ehcache.CacheException

notifyElementPut

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

Specified by:

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

Throws:

net.sf.ehcache.CacheException

notifyElementUpdated

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

Specified by:

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

Throws:

net.sf.ehcache.CacheException

notifyRemoveAll

public void notifyRemoveAll(net.sf.ehcache.Ehcache cache)

Specified by:

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

notifyElementExpired

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

Specified by:

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

notifyElementEvicted

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

Specified by:

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

replicatePutNotification

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

Throws:

net.sf.ehcache.distribution.RemoteCacheException

replicateRemovalNotification

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

Throws:

net.sf.ehcache.distribution.RemoteCacheException

replicateRemoveAllNotification

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

clone

public abstract Object clone()
                      throws CloneNotSupportedException

Specified by:

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

Overrides:

clone in class Object

Throws:

CloneNotSupportedException

dispose

public void dispose()

Specified by:

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