|
Class Summary |
| UpdateExpressionWatermark |
Implementation of Watermark in which the value is updated through a MEL
expression |
| Watermark |
Poll override that provides watermarking functionality: It enriches the event
passed to the polling message processor to have a flow variable fetched from the
object store defined, ensures the variable is carried over to the flow event if it
is going to be executed, and saves the value of the variable back to the object
store at the end of the flow. |
| WatermarkPollingInterceptor |
Implementation of MessageProcessorPollingInterceptor that retrieves the
current watermark value before the polling flow is executed and updates it when it
is finished. |
| WatermarkUtils |
|