Uses of Class
com.streambase.sb.client.StreamBaseURI

Packages that use StreamBaseURI

Package	Description
com.streambase.liveview.client	Provides classes and interfaces fundamental to the LiveView Java API.
com.streambase.sb.client	Provides classes and interfaces used to communicate with a Streaming server.
com.streambase.sb.monitor	Provides classes and interfaces to monitor the behavior of a running Streaming server.
com.streambase.sb.operator	Provides classes and interfaces to add custom operators to Streaming applications.
com.streambase.sb.unittest	Provides classes and interfaces used to author Streaming Unit tests.

Uses of StreamBaseURI in com.streambase.liveview.client

Methods in com.streambase.liveview.client that return StreamBaseURI

Modifier and Type	Method	Description
StreamBaseURI	SendTupleInfo.getSbUri()

Methods in com.streambase.liveview.client with parameters of type StreamBaseURI

Modifier and Type	Method	Description
SendTupleInfo	LiveViewConnection.getSendTupleInfo(StreamBaseURI sbUri, String targetInputStreamName, String responseOutputStreamName)	Gets the schemas associated with streams, for the purposes of using SendTupleAction.
Tuple	LiveViewConnection.sendTupleAction(StreamBaseURI sbUri, String targetInputStreamName, Tuple tuple, String responseOutputStreamName, Schema expectedResponseSchema, long timeout, TimeUnit unit)	Sends a tuple to an existing StreamBase application.

Constructors in com.streambase.liveview.client with parameters of type StreamBaseURI

Modifier	Constructor	Description
	SendTupleInfo(StreamBaseURI sbUri, String inputStreamName, String outputStreamName, Schema inputSchema, Schema outputSchema)

Uses of StreamBaseURI in com.streambase.sb.client

Fields in com.streambase.sb.client declared as StreamBaseURI

Modifier and Type	Field	Description
static final StreamBaseURI	StreamBaseURI.DEFAULT_URI	The default URI (sb://localhost:10000/) pointing to localhost, no container, port 10000).

Methods in com.streambase.sb.client that return StreamBaseURI

Modifier and Type	Method	Description
static StreamBaseURI	StreamBaseURI.fromEnvironment()	Returns the URI found by searching the following property and environment variables: Using the string value found in the streambase.uri system property, if set Using the string value found in the STREAMBASE_URI environment variable, if set Using the string value found in the STREAMBASE_SERVER environment variable, if set DEFAULT_URI if no value has been found above
StreamBaseURI	StreamBaseURI.getBaseURI()	Return a copy of this URI without any params
StreamBaseURI	DequeueResult.getServerURI()	return the server that produced this DequeueResult.
StreamBaseURI	BaseClient.getURI()	Return the URI used by this Client.
StreamBaseURI	TupleConnection.getURI()	Get URI

Methods in com.streambase.sb.client that return types with arguments of type StreamBaseURI

Modifier and Type	Method	Description
List<StreamBaseURI>	BaseClient.getURIs()	get all of the URI's for this client
static List<StreamBaseURI>	StreamBaseURI.listFromEnvironment()	Returns the list of URIs found by searching the following property and environment variables for a comma separated URI list: Using the string value found in the streambase.uri system property, if set Using the string value found in the STREAMBASE_URI environment variable, if set Using the string value found in the STREAMBASE_SERVER environment variable, if set DEFAULT_URI if no value has been above The supplied URIs must conform to a valid High Availability URI list, for example they must all reference the same container.
static List<StreamBaseURI>	StreamBaseURI.listFromString(String uriStrings)	Parse a comma-separated list of URIs in a string into a List<StreamBaseURI>.

Methods in com.streambase.sb.client with parameters of type StreamBaseURI

Modifier and Type	Method	Description
(package private) void	TupleConnections.addConnection(StreamBaseURI uri, StreamProperties props)	Add a connection
static com.streambase.sb.client.TupleIO	TupleIOFactory.makeTupleIO(StreamBaseURI uri, ClientSettings settings)
(package private) org.apache.xmlrpc.client.XmlRpcClient	XmlRpcAdmin.newXmlRpcClient(StreamBaseURI uri)	Create a new XML RPC client

Method parameters in com.streambase.sb.client with type arguments of type StreamBaseURI

Modifier and Type	Method	Description
(package private) static Admin	AdminFactory.create(List<StreamBaseURI> _uris)	Create the admin implementation object that does the actual communication to the server.
static String	HAAdmin.createBaseURIString(Collection<StreamBaseURI> uris)	Create a URI string of baseURI's from a list of uris
static String	StreamBaseURI.toSafeString(Collection<StreamBaseURI> uris)	Create a string representation of a list of uris, that is safe for logging.
static String	StreamBaseURI.toString(Collection<StreamBaseURI> uris)	Create a string representation of a list of uris.

Constructors in com.streambase.sb.client with parameters of type StreamBaseURI

Modifier	Constructor	Description
	DeMUXStreamBaseClient(StreamBaseURI streamBaseURI)	Constructor
	InternalDequeueResult(Throwable e, StreamBaseURI server)	Constructor
	SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server)	Constructor
	SocketChannelWrapper(StreamBaseURI uri, ClientSettings settings)	open the socket
	SSLSocketWrapper(StreamBaseURI uri, ClientSettings settings)
	StreamBaseAdminClient(StreamBaseURI uri)	Create a StreamBaseAdminClient, connecting to the server at the provided URI.
	StreamBaseClient(StreamBaseURI uri)	Create a StreamBaseClient, connecting to the server at the provided URI
(package private)	TupleConnection(StreamBaseURI uri, StreamBaseClient client, TupleConnections connections, long clientReadTimeout)	Constructor
(package private)	XmlRpcAdmin(StreamBaseURI uri)	Constructor

Constructor parameters in com.streambase.sb.client with type arguments of type StreamBaseURI

Modifier	Constructor	Description
(package private)	BaseClient(List<StreamBaseURI> uris, ClientSettings settings)	Construct a BaseClient with the given URI
	DeMUXStreamBaseClient(List<StreamBaseURI> uris, ClientSettings settings)	Constructor
(package private)	HAAdmin(List<StreamBaseURI> uris)	Constructor
	StreamBaseAdminClient(List<StreamBaseURI> uris)	Create a StreamBaseAdminClient.
	StreamBaseAdminClient(List<StreamBaseURI> uris, ClientSettings settings)	Create a StreamBaseAdminClient.
	StreamBaseClient(List<StreamBaseURI> uris)	Create a StreamBaseClient, connecting to the servers at the provided URIs.
	StreamBaseClient(List<StreamBaseURI> uris, ClientSettings settings)	Create a StreamBaseClient, connecting to the servers at the provided URIs.

Uses of StreamBaseURI in com.streambase.sb.monitor

Constructors in com.streambase.sb.monitor with parameters of type StreamBaseURI

Modifier	Constructor	Description
	StreamBaseMonitor(StreamBaseURI uri)	Create a monitoring object, which will connect to a server with the given StreamBase URI.

Uses of StreamBaseURI in com.streambase.sb.operator

Methods in com.streambase.sb.operator that return StreamBaseURI

Modifier and Type	Method	Description
StreamBaseURI	Operator.RuntimeEnvironment.getURI()	Return the URI of this Server.

Uses of StreamBaseURI in com.streambase.sb.unittest

Methods in com.streambase.sb.unittest that return StreamBaseURI

Modifier and Type	Method	Description
StreamBaseURI	SBServerManager.getURI()	return the URI of the StreamBase Engine