public class ClientSettings
extends java.lang.Object
StreamBaseClient
and StreamBaseAdminClient
clients.Constructor and Description |
---|
ClientSettings(boolean haModeOn)
Creates a ClientSettings that uses StreamBase default values for all settings
|
Modifier and Type | Method and Description |
---|---|
long |
getExitStatusTimeoutMS()
ExitStatusTimeoutMS is used as a timeout for how long the client
should wait to get the client's exit status from the server.
|
int |
getMaxTuplesInDequeueQueue()
The dequeue thread stores tuples to be dequeued by a client in a queue.
|
long |
getOpenTimeoutMS()
OpenTimeoutMS is used as a timeout value for opening a
binary) connection between the client and server.
|
long |
getQuiescentTimeoutMS()
QuiescentTimeoutMS is a timeout value that is used to determine how long
a client's binary connection will wait for a heartbeat message from a
server.
|
long |
getReconnectSleepMS()
How long will a client wait between reconnect attempts when in HA mode
|
long |
getWriteTimeoutMS()
WriteTimeoutMS is used as a timeout for write operations
in a binary connection between the client and server.
|
long |
getXmlRpcTimeoutMS()
XmlrpcTimeoutMS is used as a timeout for XMLRPC requests to the
server.
|
boolean |
isSocketKeepAlive()
Is SO_KEEPALIVE set
|
boolean |
isTcpNoDelay()
Is TCP_NODELAY set
|
ClientSettings |
setExitStatusTimeoutMS(long exitStatusTimeoutMS)
ExitStatusTimeoutMS is used as a timeout for how long the client
should wait to get the client's exit status from the server.
|
ClientSettings |
setMaxTuplesInDequeueQueue(int maxTuplesInDequeueQueue)
The dequeue thread stores tuples to be dequeued by a client in a queue.
|
ClientSettings |
setOpenTimeoutMS(long openTimeoutMS)
OpenTimeoutMS is used as a timeout value for opening a
binary connection between the client and server.
|
ClientSettings |
setQuiescentTimeoutMS(long quiescentTimeoutMS)
QuiescentTimeoutMS is a timeout value that is used to determine how long
a client's binary) connection will wait for a heartbeat message from a
server.
|
ClientSettings |
setReconnectSleepMS(long reconnectSleepMS)
How long will a client wait between reconnect attempts when in HA mode
|
ClientSettings |
setSocketKeepAlive(boolean socketKeepAlive)
Set SO_KEEPALIVE
|
ClientSettings |
setTcpNoDelay(boolean tcpNoDelay)
Set TCP_NODELAY
|
ClientSettings |
setWriteTimeoutMS(long writeTimeoutMS)
WriteTimeoutMS is used as a timeout for write operations
in a binary connection between the client and server.
|
ClientSettings |
setXmlRpcTimeoutMS(long xmlrpcTimeoutMS)
XmlrpcTimeoutMS is used as a timeout for XMLRPC requests to the
server.
|
public ClientSettings(boolean haModeOn)
haModeOn
- true to enable High Availability features when connecting to more than one server, false otherwise for single-server connectionspublic long getOpenTimeoutMS()
public ClientSettings setOpenTimeoutMS(long openTimeoutMS)
openTimeoutMS
- new value for the openTimeout in millisecondspublic long getWriteTimeoutMS()
public ClientSettings setWriteTimeoutMS(long writeTimeoutMS)
writeTimeoutMS
- new value for the writeTimeout in millisecondspublic long getXmlRpcTimeoutMS()
public ClientSettings setXmlRpcTimeoutMS(long xmlrpcTimeoutMS)
xmlrpcTimeoutMS
- new value for xmlrpcTimeout in millisecondspublic long getExitStatusTimeoutMS()
public ClientSettings setExitStatusTimeoutMS(long exitStatusTimeoutMS)
exitStatusTimeoutMS
- new value for exitStatusTimeout in millisecondspublic long getQuiescentTimeoutMS()
public ClientSettings setQuiescentTimeoutMS(long quiescentTimeoutMS)
quiescentTimeoutMS
- new value for quiescentTimeout in millisecondspublic long getReconnectSleepMS()
public ClientSettings setReconnectSleepMS(long reconnectSleepMS)
reconnectSleepMS
- new value for reconnectSleep in millisecondspublic int getMaxTuplesInDequeueQueue()
public ClientSettings setMaxTuplesInDequeueQueue(int maxTuplesInDequeueQueue)
maxTuplesInDequeueQueue
- new value for MaxTuplesInDequeueQueuepublic boolean isSocketKeepAlive()
SocketOptions.SO_KEEPALIVE
public ClientSettings setSocketKeepAlive(boolean socketKeepAlive)
socketKeepAlive
- enable/disable SO_KEEPALIVESocketOptions.SO_KEEPALIVE
public boolean isTcpNoDelay()
SocketOptions.TCP_NODELAY
public ClientSettings setTcpNoDelay(boolean tcpNoDelay)
tcpNoDelay
- enable/disable TCP_NODELAYSocketOptions.TCP_NODELAY