Package com.streambase.sb.client
Provides classes and interfaces used to communicate with a StreamBase server.
-
Interface Summary Interface Description ConnectionStatusCallback This interface is used to track connection lifecycle events.DeMUXStreamBaseClient.DequeueListener Implement this interface to get calls back with data when using a DeMUXStreamBaseClientDequeueResult.Interceptor A callback interface that can be implemented by an object that is associated with a StreamBaseClient and which gets used in the course of dequeuing tuples.StreamBaseClient.ListEntityFlags Flags used by the ListEntities call.XmlRpcAdmin.ListConnectionTags Connection tags -
Class Summary Class Description ClientSettings This class is used modify settings forStreamBaseClientandStreamBaseAdminClientclients.DeMUXStreamBaseClient This is a StreamBaseClient that is intended for use by several independent queries.DequeueResult Encapsulates the data returned from a dequeue() operation.SimpleDequeueResult A simple concrete implementation of DequeueResult, primarily intended for use by implementors of DequeueResult.Interceptor to allow them to construct an alternative DequeueResult.StreamBaseAdminClient This class is used to send administrative commands to the StreamBase ServerStreamBaseClient A client used to subscribe to StreamBase streams and to send commands to the StreamBase Server.StreamBaseURI A Uniform Resource Identifier containing information necessary to connect to a StreamBase server. -
Enum Summary Enum Description ConnectionStatus StreamBaseAdminClient.ListConnectionArgument Valid arguments for the listConnection command -
Exception Summary Exception Description ClientConnectException HAServerIOException Exception thrown when there's an I/O error with a HA serverNetworkException Exception thrown when a network error/problem occursProtocolException Exception thrown when a protocol error/problem occursURIException Exception thrown when URI parsing fails. -
Annotation Types Summary Annotation Type Description CustomFunctionResolver A Java annotation that can be used on a method, M, that implements a StreamBase Java custom function.