public abstract static class CacheServiceImpl.AbstractCachePubSubInvalidator extends AbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>
Modifier and Type | Field and Description |
---|---|
static String |
ALL_KEYS |
DISCRIMINATOR_SEP, discriminatorBytes, topic
Constructor and Description |
---|
AbstractCachePubSubInvalidator() |
Modifier and Type | Method and 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) |
close, initialize, scanDiscriminator, sendMessage, subscriber
public static final String ALL_KEYS
public AbstractCachePubSubInvalidator()
public CacheServiceImpl.CacheInvalidation deserialize(InputStream in) throws IOException
AbstractPubSubBroker
InputStream
into a message, or null
.deserialize
in class AbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>
IOException
public void sendInvalidation(String cacheName, String key)
public void sendInvalidationsAll(String cacheName)
public void receivedMessage(CacheServiceImpl.CacheInvalidation invalidation)
AbstractPubSubBroker
receivedMessage
in class AbstractPubSubBroker<CacheServiceImpl.CacheInvalidation>
invalidation
- the received messageCopyright © 2019 Nuxeo. All rights reserved.