org.nuxeo.runtime.pubsub

Class AbstractPubSubInvalidationsAccumulator<T extends SerializableAccumulableInvalidations>

java.lang.Object

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

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

Direct Known Subclasses:

DBSPubSubInvalidator, VCSPubSubInvalidator

public abstract class AbstractPubSubInvalidationsAccumulator<T extends SerializableAccumulableInvalidations>
extends AbstractPubSubBroker<T>

Encapsulates invalidations management through the PubSubService.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected T	bufferedInvalidations

Fields inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker

DISCRIMINATOR_SEP, discriminatorBytes, topic

Constructor Summary

Constructors

Constructor and Description
AbstractPubSubInvalidationsAccumulator()

Method Summary

Modifier and Type	Method and Description
void	close() Closes this broker and releases resources.
void	initialize(String topic, String discriminator) Initializes the broker.
abstract T	newInvalidations() Constructs new empty invalidations, of type T.
void	receivedMessage(T invalidations) Callback implementing the delivery of a message from another node.
T	receiveInvalidations() Receives invalidations from other nodes.
void	sendInvalidations(T invalidations) Sends invalidations to other nodes.

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

deserialize, scanDiscriminator, sendMessage, subscriber

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

bufferedInvalidations

protected volatile T extends SerializableAccumulableInvalidations bufferedInvalidations

Constructor Detail

AbstractPubSubInvalidationsAccumulator

public AbstractPubSubInvalidationsAccumulator()

Method Detail

newInvalidations

public abstract T newInvalidations()

Constructs new empty invalidations, of type T.

initialize

public void initialize(String topic,
                       String discriminator)

Description copied from class: AbstractPubSubBroker

Initializes the broker.

Overrides:

initialize in class AbstractPubSubBroker<T extends SerializableAccumulableInvalidations>

Parameters:

topic - the topic

discriminator - the discriminator

close

public void close()

Description copied from class: AbstractPubSubBroker

Closes this broker and releases resources.

Overrides:

close in class AbstractPubSubBroker<T extends SerializableAccumulableInvalidations>

sendInvalidations

public void sendInvalidations(T invalidations)

Sends invalidations to other nodes.

receivedMessage

public void receivedMessage(T invalidations)

Description copied from class: AbstractPubSubBroker

Callback implementing the delivery of a message from another node.

Specified by:

receivedMessage in class AbstractPubSubBroker<T extends SerializableAccumulableInvalidations>

Parameters:

invalidations - the received message

receiveInvalidations

public T receiveInvalidations()

Receives invalidations from other nodes.