org.mule.transport.polling.watermark.selector
Class WatermarkSelectorWrapper

java.lang.Object
  org.mule.transport.polling.watermark.selector.WatermarkSelector
      org.mule.transport.polling.watermark.selector.WatermarkSelectorWrapper

public class WatermarkSelectorWrapper
extends WatermarkSelector

Field Summary

Fields inherited from class org.mule.transport.polling.watermark.selector.WatermarkSelector

value

Constructor Summary

protected

WatermarkSelectorWrapper(WatermarkSelector wrapped, String selectorExpression, MuleEvent muleEvent)

Method Summary

void	acceptValue(Object value) Receives a value which is candidate to become the new watermark value.
Object	getSelectedValue() Returns the selected value.
void	reset() Returns this selector to a blank state so that it can be reused

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WatermarkSelectorWrapper

protected WatermarkSelectorWrapper(WatermarkSelector wrapped,
                                   String selectorExpression,
                                   MuleEvent muleEvent)

Method Detail

acceptValue

public void acceptValue(Object value)

Description copied from class: WatermarkSelector

Receives a value which is candidate to become the new watermark value. No thread-safeness is guaranteed by this contract. It's up to each client/implementation to handle that

Specified by:

acceptValue in class WatermarkSelector

getSelectedValue

public Object getSelectedValue()

Description copied from class: WatermarkSelector

Returns the selected value. This contract does not guarantee idempotency. Continuous invocations to this method might return different values if WatermarkSelector.acceptValue(Object) is invoked in between. Thread-safeness is also not guaranteed by this contract

Overrides:

getSelectedValue in class WatermarkSelector

Returns:

the selected value

reset

public void reset()

Description copied from class: WatermarkSelector

Returns this selector to a blank state so that it can be reused

Overrides:

reset in class WatermarkSelector