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