Uses of Class
com.streambase.sb.client.ClientSettings
Packages that use ClientSettings
Package
Description
Provides classes and interfaces used to communicate with a Streaming server.
-
Uses of ClientSettings in com.streambase.sb.client
Methods in com.streambase.sb.client that return ClientSettingsModifier and TypeMethodDescriptionClientSettings.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.Methods in com.streambase.sb.client with parameters of type ClientSettingsModifier and TypeMethodDescriptionstatic com.streambase.sb.client.TupleIOTupleIOFactory.makeTupleIO(StreamBaseURI uri, ClientSettings settings) Constructors in com.streambase.sb.client with parameters of type ClientSettingsModifierConstructorDescriptionDeMUXStreamBaseClient(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.