| Package | Description | 
|---|---|
| com.streambase.sb.client | 
 Provides classes and interfaces used to communicate with a StreamBase server. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ClientSettings | 
BaseClient.getSettings()
Return the settings for this client 
 | 
ClientSettings | 
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 | 
ClientSettings.setMaxTuplesInDequeueQueue(int maxTuplesInDequeueQueue)
The dequeue thread stores tuples to be dequeued by a client in a queue. 
 | 
ClientSettings | 
ClientSettings.setOpenTimeoutMS(long openTimeoutMS)
OpenTimeoutMS is used as a timeout value for opening a
 binary connection between the client and server. 
 | 
ClientSettings | 
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 | 
ClientSettings.setReconnectSleepMS(long reconnectSleepMS)
How long will a client wait between reconnect attempts when in HA mode 
 | 
ClientSettings | 
ClientSettings.setSocketKeepAlive(boolean socketKeepAlive)
Set SO_KEEPALIVE 
 | 
ClientSettings | 
ClientSettings.setTcpNoDelay(boolean tcpNoDelay)
Set TCP_NODELAY 
 | 
ClientSettings | 
ClientSettings.setWriteTimeoutMS(long writeTimeoutMS)
WriteTimeoutMS is used as a timeout for write operations
 in a binary connection between the client and server. 
 | 
ClientSettings | 
ClientSettings.setXmlRpcTimeoutMS(long xmlrpcTimeoutMS)
XmlrpcTimeoutMS is used as a timeout for XMLRPC requests to the
 server. 
 | 
| Constructor and Description | 
|---|
BaseClient(List<StreamBaseURI> uris,
          ClientSettings settings)
Construct a BaseClient with the given URI 
 | 
DeMUXStreamBaseClient(List<StreamBaseURI> uris,
                     ClientSettings settings)  | 
StreamBaseAdminClient(List<StreamBaseURI> uris,
                     ClientSettings settings)
Create a StreamBaseAdminClient. 
 | 
StreamBaseClient(List<StreamBaseURI> uris,
                ClientSettings settings)
Create a StreamBaseClient, connecting to the servers at the provided URIs. 
 | 
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.