org.nuxeo.ecm.core.storage.dbs

Class DBSPubSubInvalidator

java.lang.Object

org.nuxeo.ecm.core.pubsub.AbstractPubSubInvalidator<DBSInvalidations>

org.nuxeo.ecm.core.storage.dbs.DBSPubSubInvalidator

All Implemented Interfaces:

DBSClusterInvalidator

public class DBSPubSubInvalidator
extends AbstractPubSubInvalidator<DBSInvalidations>
implements DBSClusterInvalidator

PubSub implementation of DBSClusterInvalidator.

Since:

9.1

Field Summary

Fields inherited from class org.nuxeo.ecm.core.pubsub.AbstractPubSubInvalidator

bufferedInvalidations, DISCRIMINATOR_SEP, discriminatorBytes, topic

Constructor Summary

Constructors

Constructor and Description
DBSPubSubInvalidator()

Method Summary

Modifier and Type	Method and Description
DBSInvalidations	deserialize(InputStream in) Deserializes an InputStream into invalidations, or null.
void	initialize(String nodeId, String repositoryName) Initializes the invalidator.
DBSInvalidations	newInvalidations() Constructs new empty invalidations, of type T.

Methods inherited from class org.nuxeo.ecm.core.pubsub.AbstractPubSubInvalidator

close, receiveInvalidations, scanDiscriminator, sendInvalidations, 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.dbs.DBSClusterInvalidator

close, receiveInvalidations, sendInvalidations

Constructor Detail

DBSPubSubInvalidator

public DBSPubSubInvalidator()

Method Detail

newInvalidations

public DBSInvalidations newInvalidations()

Description copied from class: AbstractPubSubInvalidator

Constructs new empty invalidations, of type T.

Specified by:

newInvalidations in class AbstractPubSubInvalidator<DBSInvalidations>

deserialize

public DBSInvalidations deserialize(InputStream in)
                             throws IOException

Description copied from class: AbstractPubSubInvalidator

Deserializes an InputStream into invalidations, or null.

Specified by:

deserialize in class AbstractPubSubInvalidator<DBSInvalidations>

Throws:

IOException

initialize

public void initialize(String nodeId,
                       String repositoryName)

Description copied from class: AbstractPubSubInvalidator

Initializes the invalidator.

Specified by:

initialize in interface DBSClusterInvalidator

Overrides:

initialize in class AbstractPubSubInvalidator<DBSInvalidations>

Parameters:

nodeId - the topic

repositoryName - the discriminator