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

Constructors

Constructor	Description
VCSPubSubInvalidator()

Method Summary

Modifier and Type	Method	Description
VCSInvalidations	deserialize(InputStream in)	Deserializes an InputStream into a message, or null.
void	initialize(String nodeId, RepositoryImpl repository)	Initializes the cluster invalidator.
VCSInvalidations	newInvalidations()	Constructs new empty invalidations, of type AbstractPubSubInvalidationsAccumulator.

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 type AbstractPubSubInvalidationsAccumulator.

Specified by:

newInvalidations in class AbstractPubSubInvalidationsAccumulator<VCSInvalidations>

initialize

public void initialize(String nodeId,
                       RepositoryImpl repository)

Description copied from interface: VCSClusterInvalidator

Initializes the cluster invalidator.

Specified by:

initialize in interface VCSClusterInvalidator

Parameters:

nodeId - the cluster node id

repository - the repository

deserialize

public VCSInvalidations deserialize(InputStream in)
                             throws IOException

Description copied from class: AbstractPubSubBroker

Deserializes an InputStream into a message, or null.

Specified by:

deserialize in class AbstractPubSubBroker<VCSInvalidations>

Throws:

IOException