Package org.nuxeo.elasticsearch.core

Class ReindexingMessage

java.lang.Object

org.nuxeo.elasticsearch.core.ReindexingMessage

All Implemented Interfaces:

Serializable, SerializableMessage

public class ReindexingMessage
extends Object
implements SerializableMessage

Since:

2021.12

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
String	indexName
protected static String	NUL
String	otherIndex
String	repository
protected static String	SEP
ReindexingState	state

Constructor Summary

Constructors

Constructor	Description
ReindexingMessage(String repository, String indexName, String otherIndex, ReindexingState state)

Method Summary

Modifier and Type	Method	Description
static ReindexingMessage	deserialize(InputStream in)
boolean	equals(Object o)
int	hashCode()
void	serialize(OutputStream out)	Serializes this to an output stream.
String	toString()
protected static String	valueOf(String string)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

repository

public final String repository

indexName

public final String indexName

otherIndex

public final String otherIndex

state

public final ReindexingState state

SEP

protected static final String SEP

See Also:

Constant Field Values

NUL

protected static final String NUL

See Also:

Constant Field Values

Constructor Detail

ReindexingMessage

public ReindexingMessage(String repository,
                         String indexName,
                         String otherIndex,
                         ReindexingState state)

Parameters:

repository - being re-indexed

indexName - the name of the search index

otherIndex - the name of the second write index, or new index depending on the state

state - the state of the reindexing

Method Detail

serialize

public void serialize(OutputStream out)
               throws IOException

Description copied from interface: SerializableMessage

Serializes this to an output stream. The deserialization is handled by AbstractPubSubBroker.deserialize(java.io.InputStream).

Specified by:

serialize in interface SerializableMessage

Throws:

IOException

deserialize

public static ReindexingMessage deserialize(InputStream in)
                                     throws IOException

Throws:

IOException

valueOf

protected static String valueOf(String string)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object