ome.smuggler.core.msg

Class OnceOffRepeatConsumer<T>

java.lang.Object

ome.smuggler.core.msg.OnceOffRepeatConsumer<T>

All Implemented Interfaces:

java.util.function.Consumer<T>

public class OnceOffRepeatConsumer<T>
extends java.lang.Object
implements java.util.function.Consumer<T>

Makes message consumers returning RepeatActions work well when used for once-off schedules.

See Also:

ReschedulingSink, MessageRepeater, OnceOffSchedule

Constructor Summary

Constructors

Constructor and Description
OnceOffRepeatConsumer(RepeatConsumer<T> consumer, java.util.function.Consumer<T> exceededRedeliveryHandler) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	accept(T data)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

OnceOffRepeatConsumer

public OnceOffRepeatConsumer(RepeatConsumer<T> consumer,
                             java.util.function.Consumer<T> exceededRedeliveryHandler)

Creates a new instance.

Parameters:

consumer - consumes the message output from the channel and returns an indication of whether the same message should be delivered again.

exceededRedeliveryHandler - is given the message if the consumer asks to re-deliver.

Throws:

java.lang.NullPointerException - if any argument is null.

Method Detail

accept

public void accept(T data)

Specified by:

accept in interface java.util.function.Consumer<T>