TIBCO StreamBase client API

Types


	All Types			Classes			Interfaces			Enumerations

Name

Description

DequeueResult

Encapsulates the data returned from a dequeue() operation. Contains a stream name and a list of Tuples.

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.

LeadershipStatus

Server leadership status.

StreamBaseClient..::..ListEntitiesFlags

Flags for the listEntities call

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.

Note:

This implementation is not synchronized. If instances of this class are accessed from multiple threads, access must be synchronized. With the exception of close(), the single threaded restriction dictates that no thread may reference the object - including enqueueing - while another thread is in dequeue(). If multiple threads subscribe to streams, it is recommended that they use separate instances of this class.

StreamBaseNetworkException

A network (TCP/IP) error was encountered.

StreamBaseURI

A URI for a StreamBase client connection. These URIs are of the form

CopyC#

sb://hostname:port/;param1=val1;param2=val2

e.g.,

CopyC#

sb://somehost.mycompany.com:10000/;user=me;password=foobar

Parameters are optional. The port number is optional; it defaults to 10000.

URIException

An invalid URI was specified in a StreamBaseURI constructor.