Package org.nuxeo.ecm.core.storage.dbs

Class DBSPubSubInvalidator

java.lang.Object

org.nuxeo.runtime.pubsub.AbstractPubSubBroker<T>

org.nuxeo.runtime.pubsub.AbstractPubSubInvalidationsAccumulator<DBSInvalidations>

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

All Implemented Interfaces:

ClusterInvalidator<DBSInvalidations>, DBSClusterInvalidator

public class DBSPubSubInvalidator
extends AbstractPubSubInvalidationsAccumulator<DBSInvalidations>
implements DBSClusterInvalidator

PubSub implementation of DBSClusterInvalidator.

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
DBSPubSubInvalidator()

Method Summary

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

Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubInvalidationsAccumulator

close, 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

Constructor Detail

DBSPubSubInvalidator

public DBSPubSubInvalidator()

Method Detail

newInvalidations

public DBSInvalidations newInvalidations()

Description copied from class: AbstractPubSubInvalidationsAccumulator

Constructs new empty invalidations, of type AbstractPubSubInvalidationsAccumulator.

Specified by:

newInvalidations in class AbstractPubSubInvalidationsAccumulator<DBSInvalidations>

deserialize

public DBSInvalidations deserialize(InputStream in)
                             throws IOException

Description copied from class: AbstractPubSubBroker

Deserializes an InputStream into a message, or null.

Specified by:

deserialize in class AbstractPubSubBroker<DBSInvalidations>

Throws:

IOException

initialize

public void initialize(String nodeId,
                       String repositoryName)

Description copied from class: AbstractPubSubBroker

Initializes the broker.

Specified by:

initialize in interface DBSClusterInvalidator

Overrides:

initialize in class AbstractPubSubInvalidationsAccumulator<DBSInvalidations>

Parameters:

nodeId - the topic

repositoryName - the discriminator