See: Description
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 DeMUXStreamBaseClient
|
DequeueResult.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 |
Class | Description |
---|---|
ClientSettings |
This class is used modify settings for
StreamBaseClient and StreamBaseAdminClient
clients. |
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 Server
|
StreamBaseClient |
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 | Description |
---|---|
ConnectionStatus | |
StreamBaseAdminClient.ListConnectionArgument |
Valid arguments for the listConnection command
|
Exception | Description |
---|---|
ClientConnectException | |
HAServerIOException |
Exception thrown when there's an I/O error with a HA server
|
NetworkException |
Exception thrown when a network error/problem occurs
|
ProtocolException |
Exception thrown when a protocol error/problem occurs
|
URIException |
Exception thrown when URI parsing fails.
|
Annotation Type | Description |
---|---|
CustomFunctionResolver |
A Java annotation that can be used on a method, M, that implements a
StreamBase Java custom function.
|