public abstract class Watermark extends MessageProcessorPollingOverride
A limitation of this implementation is that the poll must be embedded into a synchronous flow. An exception will be thrown if this is not the case.
Modifier and Type | Field and Description |
---|---|
protected Map<QName,Object> |
annotations
The watermark annotations added to the definition
|
Constructor and Description |
---|
Watermark(ObjectStore<Serializable> objectStore,
String variable,
String defaultExpression) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
getUpdatedValue(MuleEvent event)
This method is executed once the flow containing the poll has been executed.
|
void |
putInto(MuleEvent event)
Retrieves the watermark value from the underlying peristent store and enriches
the event.If there is no value stored, a default expression will be used to
create a new one.
|
protected String |
resolveVariable(MuleEvent event) |
void |
updateFrom(MuleEvent event)
Updates the watermark in persistent storage based on the flow variable defined
in the event
|
void |
updateWith(MuleEvent event,
Serializable newValue) |
interceptor
public Watermark(ObjectStore<Serializable> objectStore, String variable, String defaultExpression)
public void putInto(MuleEvent event) throws ObjectStoreException
ObjectStoreException
public final void updateWith(MuleEvent event, Serializable newValue) throws ObjectStoreException
ObjectStoreException
public final void updateFrom(MuleEvent event) throws ObjectStoreException
event
- The event containing the watermark as a flow variableObjectStoreException
protected abstract Object getUpdatedValue(MuleEvent event)
event
- the MuleEvent
that was returned by the owning flowCopyright © 2003–2015 MuleSoft, Inc.. All rights reserved.