public class BackendRequestProcessor extends Object implements Service, Startable, Stoppable
BackendRequest
s 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.
Constructor and Description |
---|
BackendRequestProcessor() |
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) |
void |
stop() |
public void start(Properties properties, BuildContext context)
public void executeSync(Iterable<BackendRequest<?>> requests)
public void executeAsync(BackendRequest<?> request)
public void awaitAsyncProcessingCompletion()
Copyright © 2006–2017 Hibernate. All rights reserved.