public class VCSPubSubInvalidator extends AbstractPubSubInvalidationsAccumulator<Invalidations> implements ClusterInvalidator
ClusterInvalidator
.bufferedInvalidations
DISCRIMINATOR_SEP, discriminatorBytes, topic
Constructor and Description |
---|
VCSPubSubInvalidator() |
Modifier and Type | Method and Description |
---|---|
Invalidations |
deserialize(InputStream in)
Deserializes an
InputStream into a message, or null . |
void |
initialize(String nodeId,
RepositoryImpl repository)
Initializes the cluster invalidator.
|
Invalidations |
newInvalidations()
Constructs new empty invalidations, of type
T . |
close, initialize, receivedMessage, receiveInvalidations, sendInvalidations
scanDiscriminator, sendMessage, subscriber
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, receiveInvalidations, sendInvalidations
public VCSPubSubInvalidator()
public Invalidations newInvalidations()
AbstractPubSubInvalidationsAccumulator
T
.newInvalidations
in class AbstractPubSubInvalidationsAccumulator<Invalidations>
public void initialize(String nodeId, RepositoryImpl repository)
ClusterInvalidator
initialize
in interface ClusterInvalidator
nodeId
- the cluster node idrepository
- the repositorypublic Invalidations deserialize(InputStream in) throws IOException
AbstractPubSubBroker
InputStream
into a message, or null
.deserialize
in class AbstractPubSubBroker<Invalidations>
IOException
Copyright © 2018 Nuxeo. All rights reserved.