Uses of Class
com.streambase.sb.client.DequeueResult
Packages that use DequeueResult
Package
Description
Provides classes and interfaces used to communicate with a Streaming server.
-
Uses of DequeueResult in com.streambase.sb.client
Subclasses of DequeueResult in com.streambase.sb.clientModifier and TypeClassDescriptionclassA 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 DequeueResultModifier 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 queueDequeueResult.Interceptor.processResult(DequeueResult results) Take a DequeueResult and modify it.Methods in com.streambase.sb.client with parameters of type DequeueResultModifier and TypeMethodDescriptionvoidDeMUXStreamBaseClient.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.booleanDequeueResultsQueue.push(DequeueResult dequeueResult) Push a DequeueResult onto the queue