public class UpdateExpressionWatermark extends Watermark implements Initialisable, MuleContextAware
Watermark
in which the value is updated through a MEL
expressionannotations
PHASE_NAME
Constructor and Description |
---|
UpdateExpressionWatermark(ObjectStore<Serializable> objectStore,
String variable,
String defaultExpression,
String updateExpression) |
Modifier and Type | Method and Description |
---|---|
protected Object |
getUpdatedValue(MuleEvent event)
Returns the new watermark value by evaluating
updateExpression on the
flowVar of the given name |
void |
initialise()
Method used to perform any initialisation work.
|
MessageProcessorPollingInterceptor |
interceptor()
Returns an interceptor instance.
|
void |
setMuleContext(MuleContext muleContext) |
putInto, resolveVariable, updateFrom, updateWith
public UpdateExpressionWatermark(ObjectStore<Serializable> objectStore, String variable, String defaultExpression, String updateExpression)
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered fromprotected Object getUpdatedValue(MuleEvent event)
updateExpression
on the
flowVar of the given namegetUpdatedValue
in class Watermark
event
- the @{link MuleEvent
in which the watermark is being
evaluatedSerializable
valuepublic MessageProcessorPollingInterceptor interceptor()
MessageProcessorPollingOverride
interceptor
in class MessageProcessorPollingOverride
public void setMuleContext(MuleContext muleContext)
setMuleContext
in interface MuleContextAware
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.