public class SelectorWatermark extends Watermark implements Initialisable, MuleContextAware
Watermark
that relies on a WatermarkSelector
to
update its valuesannotations
PHASE_NAME
Constructor and Description |
---|
SelectorWatermark(ObjectStore<Serializable> objectStore,
String variable,
String defaultExpression,
WatermarkSelectorBroker selectorBroker,
String selectorExpression) |
Modifier and Type | Method and Description |
---|---|
protected Object |
getUpdatedValue(MuleEvent event)
Returns the
selectorBroker value and resets it so that its reusable. |
void |
initialise()
Method used to perform any initialisation work.
|
MessageProcessorPollingInterceptor |
interceptor()
Returns an interceptor instance.
|
void |
setMuleContext(MuleContext muleContext) |
putInto, resolveVariable, updateFrom, updateWith
public SelectorWatermark(ObjectStore<Serializable> objectStore, String variable, String defaultExpression, WatermarkSelectorBroker selectorBroker, String selectorExpression)
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)
selectorBroker
value and resets it so that its reusable. Notice
that the selectorBroker is reusable without risk of concurrency issues because
watermark only works on synchronous flowsgetUpdatedValue
in class Watermark
event
- the MuleEvent
that was returned by the owning flowpublic MessageProcessorPollingInterceptor interceptor()
interceptor
in class MessageProcessorPollingOverride
SelectorWatermarkPollingInterceptor
public void setMuleContext(MuleContext muleContext)
setMuleContext
in interface MuleContextAware
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.