Package | Description |
---|---|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleDequeueResult
A simple concrete implementation of DequeueResult, primarily intended for use by implementors of
DequeueResult.Interceptor to allow them to construct an alternative DequeueResult.
|
Modifier and Type | Method and Description |
---|---|
DequeueResult |
DeMUXStreamBaseClient.dequeue() |
DequeueResult |
StreamBaseClient.dequeue()
Dequeue a batch of tuples from a subscribed stream.
|
DequeueResult |
DeMUXStreamBaseClient.dequeue(long timeoutMS) |
DequeueResult |
StreamBaseClient.dequeue(long timeoutMS)
Dequeue a batch of tuples from a subscribed stream.
|
DequeueResult |
DequeueResult.Interceptor.processResult(DequeueResult results)
Take a DequeueResult and modify it.
|
Modifier and Type | Method and Description |
---|---|
void |
DeMUXStreamBaseClient.DequeueListener.consume(DequeueResult result)
When you register a subscribe, you will start getting called here with its results
|
DequeueResult |
DequeueResult.Interceptor.processResult(DequeueResult results)
Take a DequeueResult and modify it.
|