org.mule.transport.polling.watermark.selector

Class LastItemWatermarkSelector

java.lang.Object

org.mule.transport.polling.watermark.selector.WatermarkSelector

org.mule.transport.polling.watermark.selector.LastItemWatermarkSelector

public class LastItemWatermarkSelector
extends WatermarkSelector

Implementation of WatermarkSelector that selects the last 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

Constructors

Constructor and Description
LastItemWatermarkSelector()

Method Summary

Methods

Modifier and Type	Method and Description
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

LastItemWatermarkSelector

public LastItemWatermarkSelector()

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