Uses of Class
com.streambase.sb.client.DequeueResult
Package
Description
Provides classes and interfaces used to communicate with a Streaming server.
-
Uses of DequeueResult in com.streambase.sb.client
Modifier and TypeClassDescriptionclass
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 TypeMethodDescriptionDeMUXStreamBaseClient.dequeue()
DeMUXStreamBaseClient.dequeue
(long timeoutMS) StreamBaseClient.dequeue()
Dequeue a batch of tuples from a subscribed stream.StreamBaseClient.dequeue
(long timeoutMS) Dequeue a batch of tuples from a subscribed stream.DequeueResultsQueue.pop
(long timeoutMS) Pull a DequeueResult off of the queueDequeueResultsQueueImpl.pop
(long timeoutMS) DequeueResult.Interceptor.processResult
(DequeueResult results) Take a DequeueResult and modify it.Modifier and TypeMethodDescriptionvoid
DeMUXStreamBaseClient.DequeueListener.consume
(DequeueResult result) When you register a subscribe, you will start getting called here with its resultsDequeueResult.Interceptor.processResult
(DequeueResult results) Take a DequeueResult and modify it.boolean
DequeueResultsQueue.push
(DequeueResult dequeueResult) Push a DequeueResult onto the queueboolean
DequeueResultsQueueImpl.push
(DequeueResult item)