org.nuxeo.elasticsearch.listener

Class ElasticSearchInlineListener

java.lang.Object

org.nuxeo.elasticsearch.commands.IndexingCommandsStacker

org.nuxeo.elasticsearch.listener.ElasticSearchInlineListener

All Implemented Interfaces:

Synchronization, EventListener

public class ElasticSearchInlineListener
extends IndexingCommandsStacker
implements EventListener, Synchronization

Synchronous Event listener used to record indexing command, submitted after commit completion.

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadLocal<Boolean>	useSyncIndexing

Constructor Summary

Constructors

Constructor and Description
ElasticSearchInlineListener()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterCompletion(int status)
void	beforeCompletion()
void	handleEvent(Event event) Handle the given event.

Methods inherited from class org.nuxeo.elasticsearch.commands.IndexingCommandsStacker

stackCommand

Methods inherited from class java.lang.Object

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

Field Detail

useSyncIndexing

public static ThreadLocal<Boolean> useSyncIndexing

Constructor Detail

ElasticSearchInlineListener

public ElasticSearchInlineListener()

Method Detail

handleEvent

public void handleEvent(Event event)
                 throws ClientException

Description copied from interface: EventListener

Handle the given event. The listener can cancel the event by calling Event.cancel()

Specified by:

handleEvent in interface EventListener

Parameters:

event - the event

Throws:

ClientException

beforeCompletion

public void beforeCompletion()

Specified by:

beforeCompletion in interface Synchronization

afterCompletion

public void afterCompletion(int status)

Specified by:

afterCompletion in interface Synchronization