Package org.nuxeo.ecm.core.cache

Class CacheServiceImpl.AbstractCachePubSubInvalidator

java.lang.Object

org.nuxeo.runtime.pubsub.AbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>

org.nuxeo.ecm.core.cache.CacheServiceImpl.AbstractCachePubSubInvalidator

Direct Known Subclasses:

CacheServiceImpl.CachePubSubInvalidator

Enclosing class:

CacheServiceImpl

public abstract static class CacheServiceImpl.AbstractCachePubSubInvalidator
extends AbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>

Field Summary

Fields

Modifier and Type	Field	Description
static String	ALL_KEYS

Fields inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker

DISCRIMINATOR_SEP, discriminatorBytes, topic

Constructor Summary

Constructors

Constructor	Description
AbstractCachePubSubInvalidator()

Method Summary

Modifier and Type	Method	Description
CacheServiceImpl.CacheInvalidation	deserialize(InputStream in)	Deserializes an InputStream into a message, or null.
protected abstract Cache	getCache(String name)
void	receivedMessage(CacheServiceImpl.CacheInvalidation invalidation)	Callback implementing the delivery of a message from another node.
void	sendInvalidation(String cacheName, String key)
void	sendInvalidationsAll(String cacheName)

Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker

close, initialize, scanDiscriminator, sendMessage, subscriber

Methods inherited from class java.lang.Object

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

Field Detail

ALL_KEYS

public static final String ALL_KEYS

See Also:

Constant Field Values

Constructor Detail

AbstractCachePubSubInvalidator

public AbstractCachePubSubInvalidator()

Method Detail

deserialize

public CacheServiceImpl.CacheInvalidation deserialize(InputStream in)
                                               throws IOException

Description copied from class: AbstractPubSubBroker

Deserializes an InputStream into a message, or null.

Specified by:

deserialize in class AbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>

Throws:

IOException

sendInvalidation

public void sendInvalidation(String cacheName,
                             String key)

sendInvalidationsAll

public void sendInvalidationsAll(String cacheName)

receivedMessage

public void receivedMessage(CacheServiceImpl.CacheInvalidation invalidation)

Description copied from class: AbstractPubSubBroker

Callback implementing the delivery of a message from another node.

Specified by:

receivedMessage in class AbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>

Parameters:

invalidation - the received message

getCache

protected abstract Cache getCache(String name)