Uses of Class
com.streambase.sb.client.DequeueResult
-
Packages that use DequeueResult Package Description com.streambase.sb.client Provides classes and interfaces used to communicate with a StreamBase server. -
-
Uses of DequeueResult in com.streambase.sb.client
Subclasses of DequeueResult in com.streambase.sb.client Modifier and Type Class 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.Methods in com.streambase.sb.client that return DequeueResult Modifier and Type Method Description DequeueResult
DeMUXStreamBaseClient. dequeue()
DequeueResult
DeMUXStreamBaseClient. dequeue(long timeoutMS)
DequeueResult
StreamBaseClient. dequeue()
Dequeue a batch of tuples from a subscribed stream.DequeueResult
StreamBaseClient. dequeue(long timeoutMS)
Dequeue a batch of tuples from a subscribed stream.DequeueResult
DequeueResultsQueue. pop(long timeoutMS)
Pull a DequeueResult off of the queueDequeueResult
DequeueResult.Interceptor. processResult(DequeueResult results)
Take a DequeueResult and modify it.Methods in com.streambase.sb.client with parameters of type DequeueResult Modifier and Type Method Description void
DeMUXStreamBaseClient.DequeueListener. consume(DequeueResult result)
When you register a subscribe, you will start getting called here with its resultsDequeueResult
DequeueResult.Interceptor. processResult(DequeueResult results)
Take a DequeueResult and modify it.boolean
DequeueResultsQueue. push(DequeueResult dequeueResult)
Push a DequeueResult onto the queue
-