| 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.
|