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 TIBCO LiveView Java API.com.streambase.sb.client Provides classes and interfaces used to communicate with a StreamBase server.com.streambase.sb.monitor Provides classes and interfaces to monitor the behavior of a running StreamBase server.com.streambase.sb.operator Provides classes and interfaces to add custom operators to StreamBase applications.com.streambase.sb.unittest Provides classes and interfaces used to author StreamBase 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 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 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 thestreambase.uri
system property, if set Using the string value found in theSTREAMBASE_URI
environment variable, if set Using the string value found in theSTREAMBASE_SERVER
environment variable, if setDEFAULT_URI
if no value has been found aboveStreamBaseURI
StreamBaseURI. getBaseURI()
Return a copy of this URI without any paramsStreamBaseURI
DequeueResult. getServerURI()
return the server that produced this DequeueResult.StreamBaseURI
TupleConnection. getURI()
Get URIMethods in com.streambase.sb.client that return types with arguments of type StreamBaseURI Modifier and Type Method Description 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 thestreambase.uri
system property, if set Using the string value found in theSTREAMBASE_URI
environment variable, if set Using the string value found in theSTREAMBASE_SERVER
environment variable, if setDEFAULT_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 static TupleIO
TupleIOFactory. makeTupleIO(StreamBaseURI uri, ClientSettings settings)
Method parameters in com.streambase.sb.client with type arguments of type StreamBaseURI Modifier and Type Method Description 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 Constructor Description DeMUXStreamBaseClient(StreamBaseURI streamBaseURI)
InternalDequeueResult(Throwable e, StreamBaseURI server, Constants.LeadershipStatus leadershipStatus)
SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server, Constants.LeadershipStatus leadershipStatus)
SocketChannelWrapper(StreamBaseURI uri, ClientSettings settings)
open the socketSSLSocketWrapper(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 URIConstructor parameters in com.streambase.sb.client with type arguments of type StreamBaseURI Constructor Description DeMUXStreamBaseClient(List<StreamBaseURI> uris, ClientSettings settings)
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 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
-