Package org.nuxeo.ecm.core.storage.sql
Class VCSPubSubInvalidator
java.lang.Object
org.nuxeo.runtime.pubsub.AbstractPubSubBroker<T>
org.nuxeo.runtime.pubsub.AbstractPubSubInvalidationsAccumulator<VCSInvalidations>
org.nuxeo.ecm.core.storage.sql.VCSPubSubInvalidator
- All Implemented Interfaces:
ClusterInvalidator<VCSInvalidations>
,VCSClusterInvalidator
public class VCSPubSubInvalidator
extends AbstractPubSubInvalidationsAccumulator<VCSInvalidations>
implements VCSClusterInvalidator
PubSub implementation of the VCS
VCSClusterInvalidator
.- Since:
- 9.1
-
Field Summary
Fields inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubInvalidationsAccumulator
bufferedInvalidations
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
.void
initialize
(String nodeId, RepositoryImpl repository) Initializes the cluster invalidator.Constructs new empty invalidations, of typeAbstractPubSubInvalidationsAccumulator
.Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubInvalidationsAccumulator
close, initialize, receivedMessage, receiveInvalidations, sendInvalidations
Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker
scanDiscriminator, sendMessage, subscriber
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.nuxeo.ecm.core.storage.ClusterInvalidator
close, receiveInvalidations, sendInvalidations
Methods inherited from interface org.nuxeo.ecm.core.storage.sql.VCSClusterInvalidator
requiresClusterSQL
-
Constructor Details
-
VCSPubSubInvalidator
public VCSPubSubInvalidator()
-
-
Method Details
-
newInvalidations
Description copied from class:AbstractPubSubInvalidationsAccumulator
Constructs new empty invalidations, of typeAbstractPubSubInvalidationsAccumulator
.- Specified by:
newInvalidations
in classAbstractPubSubInvalidationsAccumulator<VCSInvalidations>
-
initialize
Description copied from interface:VCSClusterInvalidator
Initializes the cluster invalidator.- Specified by:
initialize
in interfaceVCSClusterInvalidator
- Parameters:
nodeId
- the cluster node idrepository
- the repository
-
deserialize
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<VCSInvalidations>
- Throws:
IOException
-