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
-
Method Summary
Modifier and TypeMethodDescriptionDeserializes anInputStream
into a message, ornull
.void
initialize
(String nodeId, String repositoryName) Initializes the broker.Constructs new empty invalidations, of typeAbstractPubSubInvalidationsAccumulator
.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 Details
-
DBSPubSubInvalidator
public DBSPubSubInvalidator()
-
-
Method Details
-
newInvalidations
Description copied from class:AbstractPubSubInvalidationsAccumulator
Constructs new empty invalidations, of typeAbstractPubSubInvalidationsAccumulator
.- Specified by:
newInvalidations
in classAbstractPubSubInvalidationsAccumulator<DBSInvalidations>
-
deserialize
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<DBSInvalidations>
- Throws:
IOException
-
initialize
Description copied from class:AbstractPubSubBroker
Initializes the broker.- Specified by:
initialize
in interfaceDBSClusterInvalidator
- Overrides:
initialize
in classAbstractPubSubInvalidationsAccumulator<DBSInvalidations>
- Parameters:
nodeId
- the topicrepositoryName
- the discriminator
-