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

Modifier and Type	Method	Description
DequeueResult	processResult(DequeueResult results)	Take a DequeueResult and modify it.

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