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 Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description DequeueResult
processResult(DequeueResult results)
Take a DequeueResult and modify it.
-
-
-
Method Detail
-
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
-
-