bdc90052aa
* Add CopyrightHeader support for sbt-boilerplate plugin. * Add CopyrightHeader support for `*.proto` files. * Add regex match for both `–` and `-` for CopyrightHeader. * Add CopyrightHeader support for sbt build files. * Update copyright from 2018 to 2019.
37 lines
1.1 KiB
Java
37 lines
1.1 KiB
Java
/*
|
|
* Copyright (C) 2018-2019 Lightbend Inc. <https://www.lightbend.com>
|
|
*/
|
|
|
|
package jdocs.circuitbreaker;
|
|
|
|
import akka.actor.AbstractActor;
|
|
import akka.pattern.CircuitBreaker;
|
|
import java.time.Duration;
|
|
|
|
import java.util.Optional;
|
|
import java.util.function.BiFunction;
|
|
|
|
public class EvenNoFailureJavaExample extends AbstractActor {
|
|
//#even-no-as-failure
|
|
private final CircuitBreaker breaker;
|
|
|
|
public EvenNoFailureJavaExample() {
|
|
this.breaker = new CircuitBreaker(
|
|
getContext().dispatcher(), getContext().system().scheduler(),
|
|
5, Duration.ofSeconds(10), Duration.ofMinutes(1));
|
|
}
|
|
|
|
public int luckyNumber() {
|
|
BiFunction<Optional<Integer>, Optional<Throwable>, Boolean> evenNoAsFailure =
|
|
(result, err) -> (result.isPresent() && result.get() % 2 == 0);
|
|
|
|
// this will return 8888 and increase failure count at the same time
|
|
return this.breaker.callWithSyncCircuitBreaker(() -> 8888, evenNoAsFailure);
|
|
}
|
|
|
|
//#even-no-as-failure
|
|
@Override
|
|
public Receive createReceive() {
|
|
return null;
|
|
}
|
|
}
|