Uses of Class
com.streambase.sb.client.StreamBaseClient
Packages that use StreamBaseClient
Package
Description
Provides classes and interfaces used to communicate with a Streaming server.
Provides classes and interfaces to monitor the behavior of a running Streaming server.
-
Uses of StreamBaseClient in com.streambase.sb.client
Subclasses of StreamBaseClient in com.streambase.sb.clientModifier and TypeClassDescriptionclassThis is a StreamBaseClient that is intended for use by several independent queries.Methods in com.streambase.sb.client that return StreamBaseClientMethods in com.streambase.sb.client with parameters of type StreamBaseClientModifier and TypeMethodDescriptionvoidConnectionStatusCallback.stateChanged(ConnectionStatus state, StreamBaseClient streamBaseClient, String additionalInfo) Called when the connection state changesConstructors in com.streambase.sb.client with parameters of type StreamBaseClientModifierConstructorDescription(package private)TupleConnection(StreamBaseURI uri, StreamBaseClient client, TupleConnections connections, long clientReadTimeout) Constructor(package private)TupleConnections(StreamBaseClient client, boolean haModeOn) Constructor -
Uses of StreamBaseClient in com.streambase.sb.monitor
Methods in com.streambase.sb.monitor that return StreamBaseClientModifier and TypeMethodDescriptionStreamBaseMonitor.getClient()Get theStreamBaseClientthat this monitor is usingMethods in com.streambase.sb.monitor with parameters of type StreamBaseClientModifier and TypeMethodDescriptionSnapshot.getOperatorType(StreamBaseClient sbClient, String name) Get operator type(package private) Snapshot.StatusSnapshot.readNextMonitorSnap(StreamBaseClient sbClient, Snapshot.Source source) Read the next monitor snapshot, return Status if we are done or not(package private) Snapshot.StatusSnapshotv3.readNextMonitorSnap(StreamBaseClient sbClient, Snapshot.Source source) Constructors in com.streambase.sb.monitor with parameters of type StreamBaseClientModifierConstructorDescriptionStreamBaseMonitor(StreamBaseClient client) Create a monitoring object, which will connect to a server with the given StreamBaseClient object.StreamBaseMonitor(StreamBaseClient sbClient, String streamName) Constructor