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

java.lang.Object
  org.mule.transport.polling.watermark.selector.WatermarkSelector
      org.mule.transport.polling.watermark.selector.ComparableWatermarkSelector
          org.mule.transport.polling.watermark.selector.MaxValueWatermarkSelector

public class MaxValueWatermarkSelector
extends ComparableWatermarkSelector

Implementation of WatermarkSelector that selectes the maximum value of the set. For this to work, received values need to implement the Comparable interface. Values that don't meet this condition will be discarded

Since:

3.5.0

Field Summary

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

value

Constructor Summary

MaxValueWatermarkSelector()

Method Summary

protected int

comparableQualifier() Returns an int value according to the Comparable contract (-1, 0, 1).

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

acceptValue

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

MaxValueWatermarkSelector

public MaxValueWatermarkSelector()

Method Detail

comparableQualifier

protected int comparableQualifier()

Description copied from class: ComparableWatermarkSelector

Returns an int value according to the Comparable contract (-1, 0, 1). Then the result of the comparation matches this method's return value, then the selected value is updated

Specified by:

comparableQualifier in class ComparableWatermarkSelector