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 classSimpleDequeueResultA 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 DequeueResultDeMUXStreamBaseClient. dequeue()DequeueResultDeMUXStreamBaseClient. dequeue(long timeoutMS)DequeueResultStreamBaseClient. dequeue()Dequeue a batch of tuples from a subscribed stream.DequeueResultStreamBaseClient. dequeue(long timeoutMS)Dequeue a batch of tuples from a subscribed stream.DequeueResultDequeueResultsQueue. pop(long timeoutMS)Pull a DequeueResult off of the queueDequeueResultDequeueResult.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 voidDeMUXStreamBaseClient.DequeueListener. consume(DequeueResult result)When you register a subscribe, you will start getting called here with its resultsDequeueResultDequeueResult.Interceptor. processResult(DequeueResult results)Take a DequeueResult and modify it.booleanDequeueResultsQueue. push(DequeueResult dequeueResult)Push a DequeueResult onto the queue
-