public class SelectorWatermarkPollingInterceptor extends WatermarkPollingInterceptor
WatermarkPollingInterceptor that uses
a WatermarkSelector to return the new watermark value.watermark| Constructor and Description |
|---|
SelectorWatermarkPollingInterceptor(Watermark watermark,
WatermarkSelector selector,
String selectorExpression) |
| Modifier and Type | Method and Description |
|---|---|
void |
postProcessRouting(MuleEvent event)
Watermark post processing saves the flow variable to the object store
|
MuleEvent |
prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Watermark route preparation carries the value from the source event to the
flow event
|
prepareSourceEventpublic SelectorWatermarkPollingInterceptor(Watermark watermark, WatermarkSelector selector, String selectorExpression)
public MuleEvent prepareRouting(MuleEvent sourceEvent, MuleEvent event) throws ConfigurationException
Watermark route preparation carries the value from the source event to the flow event
If the payload is a Iterable, then it is iterated passing all values
evaluated through the selector. This is so because not only different kinds of
collections can be traversed in unpredictable ways, but also collections are
often copied before being iterated in which case we have no interception
point.
If the payload is an Iterator, then a static proxy is generated so
that we can intercept all values an evaluate them through the selector.
Notice that if the Iterable or Iterator are not fully
consumed, the unretrieved values will not be received by the
WatermarkSelector
prepareRouting in class WatermarkPollingInterceptorsourceEvent - The event that was returned by the polling processorevent - The event that is about to be sent to the rest of the flowConfigurationExceptionpublic void postProcessRouting(MuleEvent event) throws ObjectStoreException
WatermarkPollingInterceptorpostProcessRouting in class WatermarkPollingInterceptorevent - The event that was routed to the rest of the flowObjectStoreExceptionCopyright © 2003–2016 MuleSoft, Inc.. All rights reserved.