com.booking.validator.utils

Class RetryFriendlySupplier<T>

java.lang.Object

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

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

All Implemented Interfaces:

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

public class RetryFriendlySupplier<T>
extends NonblockingDelayingSupplier<T>
implements Service

Created by psalimov on 11/18/16.

Constructor Summary

Constructors

Constructor and Description
RetryFriendlySupplier(java.util.function.Supplier<T> supplier, int retryQueueSoftSizeLimit)
RetryFriendlySupplier(java.util.function.Supplier<T> supplier, int retryQueueSoftSizeLimit, CurrentTimestampProvider currentTimestampProvider)

Method Summary

Modifier and Type	Method and Description
T	get()
protected void	onHighWaterMarkReached()
protected void	onLowWaterMarkReached()
void	start()
void	stop()

Methods inherited from class com.booking.validator.utils.NonblockingDelayingSupplier

accept

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.booking.validator.utils.Service

pause, resume

Constructor Detail

RetryFriendlySupplier

public RetryFriendlySupplier(java.util.function.Supplier<T> supplier,
                             int retryQueueSoftSizeLimit)

RetryFriendlySupplier

public RetryFriendlySupplier(java.util.function.Supplier<T> supplier,
                             int retryQueueSoftSizeLimit,
                             CurrentTimestampProvider currentTimestampProvider)

Method Detail

get

public T get()

Specified by:

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

Overrides:

get in class NonblockingDelayingSupplier<T>

start

public void start()

Specified by:

start in interface Service

stop

public void stop()

Specified by:

stop in interface Service

onHighWaterMarkReached

protected void onHighWaterMarkReached()

Overrides:

onHighWaterMarkReached in class NonblockingDelayingSupplier<T>

onLowWaterMarkReached

protected void onLowWaterMarkReached()

Overrides:

onLowWaterMarkReached in class NonblockingDelayingSupplier<T>