net.bluemind.lib.vertx.utils

Class CircuitBreaker<T>

java.lang.Object

net.bluemind.lib.vertx.utils.CircuitBreaker<T>

public class CircuitBreaker<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
CircuitBreaker(java.util.function.Function<T,java.lang.String> partition)

Method Summary

Modifier and Type	Method and Description
<R> java.util.concurrent.CompletableFuture<R>	apply(org.vertx.java.core.Vertx vertx, T partitionable, java.util.concurrent.Callable<R> to)
void	noticeError(T errorSource)
void	noticeSuccess(T errorSource)

Methods inherited from class java.lang.Object

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

Constructor Detail

CircuitBreaker

public CircuitBreaker(java.util.function.Function<T,java.lang.String> partition)

Method Detail

noticeError

public void noticeError(T errorSource)

noticeSuccess

public void noticeSuccess(T errorSource)

apply

public <R> java.util.concurrent.CompletableFuture<R> apply(org.vertx.java.core.Vertx vertx,
                                                           T partitionable,
                                                           java.util.concurrent.Callable<R> to)