@UriParams public class ElasticsearchConfiguration extends Object
Constructor and Description |
---|
ElasticsearchConfiguration() |
Modifier and Type | Method and Description |
---|---|
boolean |
getClientTransportSniff()
Is the client allowed to sniff the rest of the cluster or not.
|
String |
getClusterName()
Name of the cluster
|
boolean |
getEnableSSL()
Enable SSL.
|
String |
getIndexName()
The name of the index to act against
|
String |
getIndexType()
The type of the index to act against
|
String |
getIp()
The TransportClient remote host ip to use
|
ElasticsearchOperation |
getOperation()
What operation to perform
|
String |
getPassword()
Password for authenticate against the cluster.
|
String |
getPingSchedule()
The time(in unit) the client ping the cluster.
|
String |
getPingTimeout()
The time(in unit) to wait for a ping response from a node too return.
|
int |
getPort()
The TransportClient remote port to use (defaults to 9300)
|
boolean |
getTcpCompress()
true if compression (LZF) enable between all nodes.
|
String |
getTcpConnectTimeout()
The time( in unit) to wait for connection timeout.
|
String |
getTransportAddresses()
Comma separated list with ip:port formatted remote transport addresses to use.
|
List<org.elasticsearch.common.transport.InetSocketTransportAddress> |
getTransportAddressesList() |
String |
getUser()
User for authenticate against the cluster.
|
int |
getWaitForActiveShards()
Index creation waits for the write consistency number of shards to be available
|
void |
setClientTransportSniff(boolean clientTransportSniff) |
void |
setClusterName(String clusterName) |
void |
setEnableSSL(boolean enableSSL) |
void |
setIndexName(String indexName) |
void |
setIndexType(String indexType) |
void |
setIp(String ip) |
void |
setOperation(ElasticsearchOperation operation) |
void |
setPassword(String password) |
void |
setPingSchedule(String pingSchedule) |
void |
setPingTimeout(String pingTimeout) |
void |
setPort(int port) |
void |
setTcpCompress(boolean tcpCompress) |
void |
setTcpConnectTimeout(String tcpConnectTimeout) |
void |
setTransportAddresses(String transportAddresses) |
void |
setTransportAddressesList(List<org.elasticsearch.common.transport.InetSocketTransportAddress> transportAddressesList) |
void |
setUser(String user) |
void |
setWaitForActiveShards(int waitForActiveShards) |
public String getClusterName()
public void setClusterName(String clusterName)
public ElasticsearchOperation getOperation()
public void setOperation(ElasticsearchOperation operation)
public String getIndexName()
public void setIndexName(String indexName)
public String getIndexType()
public void setIndexType(String indexType)
public String getIp()
public void setIp(String ip)
public String getTransportAddresses()
public void setTransportAddresses(String transportAddresses)
public int getPort()
public void setPort(int port)
public int getWaitForActiveShards()
public void setWaitForActiveShards(int waitForActiveShards)
public boolean getClientTransportSniff()
public void setClientTransportSniff(boolean clientTransportSniff)
public List<org.elasticsearch.common.transport.InetSocketTransportAddress> getTransportAddressesList()
public void setTransportAddressesList(List<org.elasticsearch.common.transport.InetSocketTransportAddress> transportAddressesList)
public String getPingSchedule()
public void setPingSchedule(String pingSchedule)
public String getTcpConnectTimeout()
public void setTcpConnectTimeout(String tcpConnectTimeout)
public boolean getTcpCompress()
public void setTcpCompress(boolean tcpCompress)
public String getUser()
public void setUser(String user)
public String getPassword()
public void setPassword(String password)
public boolean getEnableSSL()
public void setEnableSSL(boolean enableSSL)
public String getPingTimeout()
public void setPingTimeout(String pingTimeout)
Apache Camel