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 inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker
DISCRIMINATOR_SEP, discriminatorBytes, topic
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionDeserializes anInputStream
into a message, ornull
.protected abstract Cache
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 Details
-
ALL_KEYS
- See Also:
-
-
Constructor Details
-
AbstractCachePubSubInvalidator
public AbstractCachePubSubInvalidator()
-
-
Method Details
-
deserialize
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>
- Throws:
IOException
-
sendInvalidation
-
sendInvalidationsAll
-
receivedMessage
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
-
getCache
-