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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description CacheServiceImpl.CacheInvalidation
deserialize(InputStream in)
Deserializes anInputStream
into a message, ornull
.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
-
-
-
-
Field Detail
-
ALL_KEYS
public static final String ALL_KEYS
- See Also:
- Constant Field Values
-
-
Method Detail
-
deserialize
public CacheServiceImpl.CacheInvalidation deserialize(InputStream in) throws IOException
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>
- Throws:
IOException
-
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 classAbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>
- Parameters:
invalidation
- the received message
-
-