diff --git a/akka-docs/src/test/java/jdocs/circuitbreaker/DangerousJavaActor.java b/akka-docs/src/test/java/jdocs/circuitbreaker/DangerousJavaActor.java index 7f8c3eda72..52d8b617fd 100644 --- a/akka-docs/src/test/java/jdocs/circuitbreaker/DangerousJavaActor.java +++ b/akka-docs/src/test/java/jdocs/circuitbreaker/DangerousJavaActor.java @@ -27,7 +27,7 @@ public class DangerousJavaActor extends AbstractActor { this.breaker = new CircuitBreaker( getContext().dispatcher(), getContext().system().scheduler(), 5, Duration.create(10, "s"), Duration.create(1, "m")) - .onOpen(this::notifyMeOnOpen); + .addOnOpenListener(this::notifyMeOnOpen); } public void notifyMeOnOpen() {