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 VCSVCSClusterInvalidator
.- 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
Constructors Constructor Description VCSPubSubInvalidator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description VCSInvalidations
deserialize(InputStream in)
Deserializes anInputStream
into a message, ornull
.void
initialize(String nodeId, RepositoryImpl repository)
Initializes the cluster invalidator.VCSInvalidations
newInvalidations()
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 Detail
-
VCSPubSubInvalidator
public VCSPubSubInvalidator()
-
-
Method Detail
-
newInvalidations
public VCSInvalidations newInvalidations()
Description copied from class:AbstractPubSubInvalidationsAccumulator
Constructs new empty invalidations, of typeAbstractPubSubInvalidationsAccumulator
.- Specified by:
newInvalidations
in classAbstractPubSubInvalidationsAccumulator<VCSInvalidations>
-
initialize
public void initialize(String nodeId, RepositoryImpl repository)
Description copied from interface:VCSClusterInvalidator
Initializes the cluster invalidator.- Specified by:
initialize
in interfaceVCSClusterInvalidator
- Parameters:
nodeId
- the cluster node idrepository
- the repository
-
deserialize
public VCSInvalidations deserialize(InputStream in) throws IOException
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<VCSInvalidations>
- Throws:
IOException
-
-