org.mule.transport.polling.watermark
Class WatermarkPollingInterceptor
java.lang.Object
org.mule.transport.polling.MessageProcessorPollingInterceptor
org.mule.transport.polling.watermark.WatermarkPollingInterceptor
- Direct Known Subclasses:
- SelectorWatermarkPollingInterceptor
public class WatermarkPollingInterceptor
- extends MessageProcessorPollingInterceptor
Implementation of MessageProcessorPollingInterceptor
that retrieves the
current watermark value before the polling flow is executed and updates it when it
is finished.
- Since:
- 3.5.0
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
watermark
protected final Watermark watermark
WatermarkPollingInterceptor
public WatermarkPollingInterceptor(Watermark watermark)
prepareSourceEvent
public MuleEvent prepareSourceEvent(MuleEvent event)
throws MuleException
- Watermark source preprocessing puts the watermark value into a flow variable
- Overrides:
prepareSourceEvent
in class MessageProcessorPollingInterceptor
- Parameters:
event
- The event that is about to be sent
- Returns:
- The event that should be sent. Must not be null
- Throws:
MuleException
prepareRouting
public MuleEvent prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
throws ConfigurationException
- Watermark route preparation carries the value from the source event to the
flow event
- Overrides:
prepareRouting
in class MessageProcessorPollingInterceptor
- Parameters:
sourceEvent
- The event that was returned by the polling processorevent
- The event that is about to be sent to the rest of the flow
- Returns:
- The event that should be sent to the rest of the flow. Must not be null
- Throws:
ConfigurationException
postProcessRouting
public void postProcessRouting(MuleEvent event)
throws ObjectStoreException
- Watermark post processing saves the flow variable to the object store
- Overrides:
postProcessRouting
in class MessageProcessorPollingInterceptor
- Parameters:
event
- The event that was routed to the rest of the flow
- Throws:
ObjectStoreException
Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.