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

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

public class FirstItemWatermarkSelector
extends WatermarkSelector

Implementation of WatermarkSelector that selects the first value of the set. Thread-safeness is not guaranteed. If your use case is concurrent, then you need to synchronize access yourself.

Since:

3.5.0

Field Summary

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

value

Constructor Summary

FirstItemWatermarkSelector()

Method Summary

void	acceptValue(Object value) Receives a value which is candidate to become the new watermark value.

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

getSelectedValue, reset

Methods inherited from class java.lang.Object

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

Constructor Detail

FirstItemWatermarkSelector

public FirstItemWatermarkSelector()

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