Uses of Class
com.streambase.sb.client.ClientSettings
Package
Description
Provides classes and interfaces used to communicate with a Streaming server.
-
Uses of ClientSettings in com.streambase.sb.client
Modifier and TypeMethodDescriptionBaseClient.getSettings()
Return the settings for this clientClientSettings.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 modeClientSettings.setSocketKeepAlive
(boolean socketKeepAlive) Set SO_KEEPALIVEClientSettings.setTcpNoDelay
(boolean tcpNoDelay) Set TCP_NODELAYClientSettings.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.Modifier and TypeMethodDescriptionstatic com.streambase.sb.client.TupleIO
TupleIOFactory.makeTupleIO
(StreamBaseURI uri, ClientSettings settings) ModifierConstructorDescription(package private)
BaseClient
(List<StreamBaseURI> uris, ClientSettings settings) Construct a BaseClient with the given URIDeMUXStreamBaseClient
(List<StreamBaseURI> uris, ClientSettings settings) ConstructorSocketChannelWrapper
(StreamBaseURI uri, ClientSettings settings) open the socketSocketChannelWrapper
(String host, int port, ClientSettings settings) open the socketSocketChannelWrapper
(SocketChannel channel, ClientSettings settings) open the socketSSLSocketWrapper
(StreamBaseURI uri, 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.