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	repository
String	secondWriteIndexName
protected static String	SEP
ReindexingState	state

Constructor Summary

Constructors

Constructor	Description
ReindexingMessage(String repository, String indexName, String secondIndexName, 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

secondWriteIndexName

public final String secondWriteIndexName

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 secondIndexName,
                         ReindexingState state)

Parameters:

repository - being re-indexed

indexName - the name of the search index

secondIndexName - the name of the second write index

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