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