| Package | Description |
|---|---|
| com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
| Modifier and Type | Method and Description |
|---|---|
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 |
|---|
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.
|