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

Constructors

Constructor	Description
ReindexingPubSub()

Method Summary

Modifier and Type	Method	Description
ReindexingMessage	deserialize(InputStream in)	Deserializes an InputStream into a message, or null.
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

Methods inherited from class java.lang.Object

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

Constructor Detail

ReindexingPubSub

public ReindexingPubSub()

Method Detail

deserialize

public ReindexingMessage deserialize(InputStream in)
                              throws IOException

Description copied from class: AbstractPubSubBroker

Deserializes an InputStream into a message, or null.

Specified by:

deserialize in class AbstractPubSubBroker<ReindexingMessage>

Throws:

IOException

sendMessage

public void sendMessage(ReindexingMessage message)

Description copied from class: AbstractPubSubBroker

Sends a message to other nodes.

Overrides:

sendMessage in class AbstractPubSubBroker<ReindexingMessage>

receivedMessage

public void receivedMessage(ReindexingMessage message)

Description copied from class: AbstractPubSubBroker

Callback implementing the delivery of a message from another node.

Specified by:

receivedMessage in class AbstractPubSubBroker<ReindexingMessage>

Parameters:

message - the received message