The StreamBaseClient type exposes the following methods.
Methods
 Public Protected | Instance Static | Declared Inherited | XNA Framework Only .NET Compact Framework Only |
| Member | Description | |||
|---|---|---|---|---|
 | CanDequeue()()()() |
Returns true if the client currently has tuples to dequeue.
| ||
| Close()()()() |
Terminate the client. May be invoked from a different thread.
StreamBaseClient memory, network, and thread resources are not released
until close() is called.
Returns immediately.
| ||
| Dequeue()()()() |
Dequeue tuples from any subscribed stream. This method
blocks until
| ||
| Dequeue(Int32) |
Dequeue a batch of tuples from a subscribed stream. This
method will block until:
| ||
| Describe(String) |
Return an XML description of the named StreamBase entity
| ||
| EnableBuffering(Int32) |
Turn on buffering with a default flush value of 250ms.
| ||
| EnableBuffering(Int32, Int32) |
Turn on buffering. The WakeAndFlushBuffer thread is only started if nFlushIntervalInMS > 0.
| ||
| EnableHeartbeating()()()() |
Enables heartbeating for enqueue-only clients.
| ||
| Enqueue(String, Tuple) |
Enqueue a tuple to the named stream. The stream must not be tied to
the output of any operator in the application. This method can block
depending on network, or StreamBase server, congestion.
| ||
| Enqueue(String, List<(Of <<'(Tuple>)>>)) |
Enqueue tuples to the named stream. The stream must not be tied to
the output of any operator in the application. This method can block
depending on network, or StreamBase server, congestion.
| ||
| Enqueue(StreamProperties, Tuple) |
Enqueue a tuple to a stream. The stream must not be tied to
the output of any operator in the application. This method can block
depending on network, or StreamBase server, congestion.
| ||
| Enqueue(StreamProperties, List<(Of <<'(Tuple>)>>)) |
Enqueue tuples to a stream. The stream must not be tied to
the output of any operator in the application. This method can block
depending on network, or StreamBase server, congestion.
| ||
| Equals(Object) | Determines whether the specified Object is equal to the current Object. (Inherited from Object.) | ||
| FlushAllBuffers()()()() |
Flush any pending enqueue buffers.
This operation has no effect if buffering is not enabled.
| ||
| FlushBuffer(String) |
Flush any pending enqueue buffer for the stream name provided.
This operation has no effect if buffering is not enabled or
there is no buffer to flush for the given stream.
| ||
| FlushBuffer(StreamProperties) |
Flush any pending enqueue buffer for the StreamProperties provided.
This operation has no effect if buffering is not enabled or
there is no buffer to flush for the given stream.
| ||
| GetConnectionID()()()() |
Return the Connection ID for this Client Connection. Only Valid once
an enqueue/dequeue has been attempted.
| ||
| GetDequeueResultInterceptor()()()() |
Get the current dequeue results interceptor, or null if there is none.
| ||
| GetDynamicVariables(String) |
Get all the dynamic variables in the given module, and return them
as a Tuple where the field names are the names of the dynamic variables,
and the field values are the current values of the dynamic variables.
| ||
| GetHashCode()()()() | Serves as a hash function for a particular type. (Inherited from Object.) | ||
| GetSchemaByHash(array<Byte>[]()[][]) |
Return the Schema object for the given hash value
| ||
| GetSchemaByName(String) |
Get a schema by name. This will only succeed for named schemas; unnamed schemas assigned to a stream
should instead be looked up by using the Schema for the given stream
as returned by GetStreamProperties(String) | ||
| GetSchemaForStream(String) |
Returns the schema of a stream, throwing an exception if the
stream does not exist.
| ||
| GetStreamProperties(String) |
Returns a description of a stream, throwing an exception if the
stream does not exist.
| ||
| GetStreamPropertiesByHash(array<Byte>[]()[][]) |
Return the StreamProperties object for the given hash value
| ||
| GetType()()()() | Gets the Type of the current instance. (Inherited from Object.) | ||
| GetURI()()()() |
Get the URI of the server to which we're connected.
| ||
| GetURIs()()()() |
Get the URIs of the servers to which we're connected.
| ||
 | GetVersion()()()() |
Returns the client version as a string
| ||
| IsClosed()()()() |
Return true if the client connection is closed.
The client connection can be closed by calling the Close() method,
by a server shutdown, or a network error.
| ||
| IsConnected()()()() |
Returns true if the client has any active connections to StreamBase Servers.
| ||
| IsStreamSubscribed(String) | |||
| ListEntities(EntityType) |
Lists all entities of a particular type.
| ||
| ListEntities(String, StreamBaseClient..::..ListEntitiesFlags) |
Lists all entities of a particular type.
Use the given flags to list the entities.
| ||
| ListEntities(EntityType, StreamBaseClient..::..ListEntitiesFlags) |
Lists all entities of a particular type.
Use the given flags to list the entities.
| ||
| ReadTable(String, Int32) |
Return rows from a Query Table or Materialized Window. No guarantees are made regarding the order of rows returned.
| ||
| ReadTable(String, Int32, String) |
Return rows from a Query Table or Materialized Window, applying an optional predicate to decide which rows are returned.
No guarantees are made regarding the order of rows returned.
| ||
| Resubscribe(String, String, String) |
Resubscribes to a stream with a predicate to apply to output tuples.
The stream name of dequeued tuples is sLogicalStream.
When unsubscribing, use sLogicalStream.
| ||
| Resubscribe(StreamProperties, String, String) |
Reubscribes to a stream with a predicate to apply to output tuples.
The stream name of dequeued tuples is sLogicalStream.
When unsubscribing, use sLogicalStream.
| ||
| SetDequeueResultInterceptor(DequeueResult..::..Interceptor) |
Set the dequeue results interceptor for this client connection.
This results interceptor replaces any existing results processor. To
disable pre-processing of results, set the processor to null.
| ||
| setDynamicVariable(String, String) |
Deprecated: use the uppercase 'S' version
| ||
| SetDynamicVariable(String, String) |
Set the dynamic variable at the given path to the given value, expressed
as a string in CSV style.
| ||
| SetQuiescentLimit(Int32) |
Sets how many milliseconds a dequeueing client will tolerate not receiving a client heart
beat from the StreamBase server that it is connected to. The default value is
120000 (120 seconds). By default, StreamBase servers emit "client heart beats"
every 10 seconds so StreamBase applications have no requirement to send data regularly.
| ||
| Status()()()() |
Return the status of the StreamBase Server
| ||
| Status(Boolean) |
Return the status of the StreamBase Server
| ||
| Subscribe(String) |
Subscribes to the named stream.
| ||
| Subscribe(StreamProperties) |
Subscribes to the given stream.
| ||
| Subscribe(String, String, String) |
Subscribes to a stream with a predicate to apply to output tuples.
The stream name of dequeued tuples is sLogicalStream.
When unsubscribing, use sLogicalStream.
| ||
| Subscribe(StreamProperties, String, String) |
Subscribes to a stream with a predicate to apply to output tuples.
The stream name of dequeued tuples is sLogicalStream.
When unsubscribing, use sLogicalStream.
| ||
| ToString()()()() | Returns a string that represents the current object. (Inherited from Object.) | ||
| Typecheck(String) |
Typecheck (validate) the given StreamBase Application.
| ||
| Typecheck(String, Boolean) |
Typecheck (validate) the given StreamBase Application.
| ||
| Unsubscribe(String) |
Unsubscribes from the named stream.
| ||
| Unsubscribe(StreamProperties) |
Unsubscribes from the given stream.
|
Note:See Also
