com.booking.validator.utils

Class NonblockingDelayingSupplier<T>

java.lang.Object

com.booking.validator.utils.NonblockingDelayingSupplier<T>

All Implemented Interfaces:

Retrier<T>, java.util.function.Supplier<T>

Direct Known Subclasses:

RetryFriendlySupplier

public class NonblockingDelayingSupplier<T>
extends Object
implements java.util.function.Supplier<T>, Retrier<T>

Created by psalimov on 11/18/16.

Constructor Summary

Constructors

Constructor and Description
NonblockingDelayingSupplier(int highWaterMark, int lowWaterMark)
NonblockingDelayingSupplier(int highWaterMark, int lowWaterMark, CurrentTimestampProvider currentTimestampProvider)

Method Summary

Modifier and Type	Method and Description
void	accept(T value, long delay)
T	get()
protected void	onHighWaterMarkReached()
protected void	onLowWaterMarkReached()

Methods inherited from class java.lang.Object

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

Constructor Detail

NonblockingDelayingSupplier

public NonblockingDelayingSupplier(int highWaterMark,
                                   int lowWaterMark)

NonblockingDelayingSupplier

public NonblockingDelayingSupplier(int highWaterMark,
                                   int lowWaterMark,
                                   CurrentTimestampProvider currentTimestampProvider)

Method Detail

get

public T get()

Specified by:

get in interface java.util.function.Supplier<T>

accept

public void accept(T value,
                   long delay)

Specified by:

accept in interface Retrier<T>

onHighWaterMarkReached

protected void onHighWaterMarkReached()

onLowWaterMarkReached

protected void onLowWaterMarkReached()