Uses of Class
com.streambase.sb.StreamProperties

Packages that use StreamProperties

Package	Description
com.streambase.sb	Provides classes and interfaces fundamental to the Streaming 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.unittest	Provides classes and interfaces used to author Streaming Unit tests.

Uses of StreamProperties in com.streambase.sb

Methods in com.streambase.sb that return StreamProperties

Modifier and Type	Method	Description
static StreamProperties	SBUtils.newStreamProperties(String xmlstring, ByteOrder order)	Create new stream properties from XML string
static StreamProperties	SBUtils.newStreamProperties(Element element, ByteOrder order)	Create new stream properties from XML element

Uses of StreamProperties in com.streambase.sb.client

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

Modifier and Type	Field	Description
protected final StreamProperties	DequeueResult.props	Stream properties

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

Modifier and Type	Method	Description
StreamProperties	Admin.getStreamProperties(long timeoutMS, String streamName)	Return the StreamProperties for the given name.
StreamProperties	Admin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)	Return the StreamProperties for the given name.
StreamProperties	DequeueResult.getStreamProperties()	Return the StreamProperties for this DequeueResult.
StreamProperties	HAAdmin.getStreamProperties(long timeoutMS, String streamName)
StreamProperties	HAAdmin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)
StreamProperties	StreamBaseClient.getStreamProperties(String streamName)	Return the StreamProperties for the given stream name
StreamProperties	StreamBaseClient.getStreamProperties(String streamName, CaptureTransformStrategy strategy)	Return the StreamProperties for the given stream name
StreamProperties	XmlRpcAdmin.getStreamProperties(long timeoutMS, String streamName)
StreamProperties	XmlRpcAdmin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)
StreamProperties	Admin.getStreamPropertiesByHash(long timeoutMS, byte[] hash)	Return the StreamProperties for the given hash
StreamProperties	HAAdmin.getStreamPropertiesByHash(long timeoutMS, byte[] hash)
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(byte[] hash)	Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(String hashHexString)	Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
StreamProperties	XmlRpcAdmin.getStreamPropertiesByHash(long timeoutMS, byte[] hash)
StreamProperties	StreamBaseClient.TupleBuffer.props()	get stream properties for this Buffer
(package private) StreamProperties	SubscriptionEntry.props()
StreamProperties	DeMUXStreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.resubscribe(String streamname, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(StreamProperties props, String logicalStream, String predicate)	Resubscribe to a stream with a predicate.
StreamProperties	StreamBaseClient.resubscribe(String streamname, String logicalstream, String predicate)	Resubscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props)
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, String logicalStream, String predicate, DeMUXStreamBaseClient.DequeueListener listener)	This is the only subscribe operation that is supported by the DeMUXStreamBaseClient
StreamProperties	StreamBaseClient.subscribe(StreamProperties props)	Subscribe to a stream
StreamProperties	StreamBaseClient.subscribe(StreamProperties props, String logicalStream, String predicate)	Subscribe to a stream with a predicate.
StreamProperties	StreamBaseClient.subscribe(String streamname)	Subscribe to a stream
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy)	Subscribe to a stream
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)	Subscribe to a stream with a predicate.
StreamProperties	StreamBaseClient.subscribe(String streamname, String logicalstream, String predicate)	Subscribe to a stream with a predicate.
StreamProperties[]	Admin.typecheck(long timeoutMS, String application, boolean full)	Typecheck (validate) the given StreamBase Application.
StreamProperties[]	HAAdmin.typecheck(long timeoutMS, String application, boolean full)
StreamProperties[]	StreamBaseClient.typecheck(String application)	Typecheck (validate) the given StreamBase Application.
StreamProperties[]	StreamBaseClient.typecheck(String application, boolean full)	Typecheck (validate) the given StreamBase Application.
StreamProperties[]	XmlRpcAdmin.typecheck(long timeoutMS, String application, boolean full)

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

Modifier and Type	Method	Description
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type)	Return all the StreamProperties available.
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type, CaptureTransformStrategy strategy)	Return all the StreamProperties available

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

Modifier and Type	Method	Description
(package private) void	TupleConnections.addConnection(StreamBaseURI uri, StreamProperties props)	Add a connection
protected static String	StreamBaseClient.assureNameStartsWithContainer(StreamProperties base, String logicalName)	Ensure name starts with container
boolean	StreamBaseClient.TupleBuffer.canDequeue(StreamProperties props)	Can dequeue?
boolean	StreamBaseClient.TupleBuffer.canEnqueue(StreamProperties props)	Can enqueue?
void	Admin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)	Enqueue a list of CSV encoded tuples using connectionless XMLRPC
void	HAAdmin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)
void	StreamBaseClient.enqueue(StreamProperties props, Tuple tuple)	Enqueue a single Tuple onto a stream.
void	StreamBaseClient.enqueue(StreamProperties props, Collection<Tuple> tuples)	Enqueue a collection of Tuples onto a stream.
void	XmlRpcAdmin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)
void	StreamBaseClient.flushBuffer(StreamProperties props)	Deprecated. use StreamBaseClient.flushAllBuffers() to preserve inter-stream ordering
(package private) List<TupleConnections.StreamTupleConnection>	TupleConnections.getConnections(StreamProperties props)	Return an unmodifiable list of List<StreamConnection>
protected static String	DeMUXStreamBaseClient.getFullLogicalName(StreamProperties streamProperties)	Get full logical name
boolean	DeMUXStreamBaseClient.isSubscribed(StreamProperties stream)
boolean	StreamBaseClient.isSubscribed(StreamProperties stream)	Return status if we are subscribed to the given stream
(package private) void	SubscriptionEntry.resetProperties(StreamProperties newProps)
StreamProperties	DeMUXStreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(StreamProperties props, String logicalStream, String predicate)	Resubscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props)
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(StreamProperties props)	Subscribe to a stream
StreamProperties	StreamBaseClient.subscribe(StreamProperties props, String logicalStream, String predicate)	Subscribe to a stream with a predicate.
void	Admin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<TupleConnections.StreamTupleConnection> connections)	UnSubscribe to an output stream.
void	DeMUXStreamBaseClient.unsubscribe(StreamProperties logicalProps)
void	HAAdmin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<TupleConnections.StreamTupleConnection> connections)
void	StreamBaseClient.unsubscribe(StreamProperties logicalProps)	Unsubscribe from the given stream name.
(package private) void	TupleConnection.unsubscribe(long timeoutMS, StreamProperties props, String logicalStream)	Unsubscribe internal control stream
void	XmlRpcAdmin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<TupleConnections.StreamTupleConnection> connections)
protected void	StreamBaseClient.unsubscribeInternal(StreamProperties logicalProps)	Un-subscribe from stream

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

Modifier	Constructor	Description
(package private)	SerializedTupleBuffer(StreamProperties props)	Constructor
	SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server)	Constructor
(package private)	StreamTupleConnection(StreamProperties props, com.streambase.sb.client.TupleConnection connection)	Constructor
(package private)	SubscriptionEntry(StreamProperties props, String logicalName, String predicate)
(package private)	TupleBuffer(StreamProperties props)	Constructor

Uses of StreamProperties in com.streambase.sb.monitor

Methods in com.streambase.sb.monitor that return StreamProperties

Modifier and Type	Method	Description
StreamProperties	StreamInfo.getStreamProperties()	Returns the StreamProperties of the stream

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

Modifier	Constructor	Description
(package private)	StreamInfo(StreamProperties props)	Constructor

Uses of StreamProperties in com.streambase.sb.unittest

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

Modifier and Type	Method	Description
StreamProperties	Dequeuer.getStreamProperties()	Get the StreamProperties for the associated stream.
StreamProperties	Enqueuer.getStreamProperties()	Get the StreamProperties for the associated stream.