org.hibernate.search.elasticsearch.client.impl

Class BackendRequestProcessor

java.lang.Object

org.hibernate.search.elasticsearch.client.impl.BackendRequestProcessor

All Implemented Interfaces:

Service, Startable, Stoppable

public class BackendRequestProcessor
extends Object
implements Service, Startable, Stoppable

Executes single or multiple BackendRequests against the Elasticsearch server. When processing multiple requests, bulk requests will be formed and executed as far as possible.

Requests can be processed synchronously or asynchronously. In the latter case, incoming requests are added to a queue via AsyncBackendRequestProcessor from where a worker runnable will process them in bulks.

Author:

Gunnar Morling

Constructor Summary

Constructors

Constructor and Description
BackendRequestProcessor()

Method Summary

Modifier and Type	Method and Description
void	awaitAsyncProcessingCompletion() Blocks until the queue of requests scheduled for asynchronous processing has been fully processed.
void	executeAsync(BackendRequest<?> request)
void	executeSync(Iterable<BackendRequest<?>> requests)
void	start(Properties properties, BuildContext context) Start phase notification.
void	stop() Stop phase notification

Methods inherited from class java.lang.Object

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

Constructor Detail

BackendRequestProcessor

public BackendRequestProcessor()

Method Detail

start

public void start(Properties properties,
                  BuildContext context)

Description copied from interface: Startable

Start phase notification.

Specified by:

start in interface Startable

Parameters:

properties - the configuration properties

context - the current context instance

stop

public void stop()

Description copied from interface: Stoppable

Stop phase notification

Specified by:

stop in interface Stoppable

executeSync

public void executeSync(Iterable<BackendRequest<?>> requests)

executeAsync

public void executeAsync(BackendRequest<?> request)

awaitAsyncProcessingCompletion

public void awaitAsyncProcessingCompletion()

Blocks until the queue of requests scheduled for asynchronous processing has been fully processed. N.B. if more work is added to the queue in the meantime, this might delay the wait.