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() |
execute
protected 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 AbstractElasticsearchProxy
protected void reportMessage(java.lang.String message)
reportMessage
in class AbstractElasticsearchProxy
protected void reportFailure(java.lang.String message, java.lang.Exception failure)
reportFailure
in class AbstractElasticsearchProxy
public final void close()
protected void closeHook()