public class SharedElasticsearchProxy extends AbstractElasticsearchProxy
ElasticsearchProxy.Task<T>| Modifier and Type | Field and Description |
|---|---|
protected ElasticsearchOptions |
options |
| Constructor and Description |
|---|
SharedElasticsearchProxy(ElasticsearchOptions options) |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.collect.ImmutableList<org.elasticsearch.common.transport.TransportAddress> |
addresses() |
protected org.elasticsearch.client.transport.TransportClient |
client() |
void |
close() |
protected void |
closeHook() |
protected void |
reportFailure(java.lang.String message,
java.lang.Exception failure) |
protected void |
reportMessage(java.lang.String message) |
org.elasticsearch.common.settings.Settings |
settings() |
org.elasticsearch.common.settings.Settings |
update() |
executeprotected final ElasticsearchOptions options
public SharedElasticsearchProxy(ElasticsearchOptions options)
public final com.google.common.collect.ImmutableList<org.elasticsearch.common.transport.TransportAddress> addresses()
public final org.elasticsearch.common.settings.Settings settings()
public final org.elasticsearch.common.settings.Settings update()
protected final org.elasticsearch.client.transport.TransportClient client()
client in class AbstractElasticsearchProxyprotected void reportMessage(java.lang.String message)
reportMessage in class AbstractElasticsearchProxyprotected void reportFailure(java.lang.String message,
java.lang.Exception failure)
reportFailure in class AbstractElasticsearchProxypublic final void close()
protected void closeHook()