Package org.nuxeo.elasticsearch.core
Class ElasticSearchAdminImpl.ReindexingPubSub
java.lang.Object
org.nuxeo.runtime.pubsub.AbstractPubSubBroker<ReindexingMessage>
org.nuxeo.elasticsearch.core.ElasticSearchAdminImpl.ReindexingPubSub
- Enclosing class:
- ElasticSearchAdminImpl
public class ElasticSearchAdminImpl.ReindexingPubSub
extends AbstractPubSubBroker<ReindexingMessage>
-
Field Summary
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
receivedMessage
(ReindexingMessage message) Callback implementing the delivery of a message from another node.void
sendMessage
(ReindexingMessage message) Sends a message to other nodes.Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker
close, initialize, scanDiscriminator, subscriber
-
Constructor Details
-
ReindexingPubSub
public ReindexingPubSub()
-
-
Method Details
-
deserialize
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<ReindexingMessage>
- Throws:
IOException
-
sendMessage
Description copied from class:AbstractPubSubBroker
Sends a message to other nodes.- Overrides:
sendMessage
in classAbstractPubSubBroker<ReindexingMessage>
-
receivedMessage
Description copied from class:AbstractPubSubBroker
Callback implementing the delivery of a message from another node.- Specified by:
receivedMessage
in classAbstractPubSubBroker<ReindexingMessage>
- Parameters:
message
- the received message
-