Package com.streambase.sb.client

Interface DequeueResult.Interceptor

Enclosing class:
DequeueResult
public static interface DequeueResult.Interceptor
A callback interface that can be implemented by an object that is associated with a StreamBaseClient and which gets used in the course of dequeuing tuples.
Since:
5.1

  • Method Details

    • processResult

      DequeueResult processResult(DequeueResult results)
      Take a DequeueResult and modify it. Returns the same object if there are no changes. Returns null if the dequeue results should be suppressed. May return a different DequeueResult object.
      Parameters:
      results - The in bound results
      Returns:
      possibly modified dequeue result
      Since:
      5.1