diff --git a/akka-docs/rst/common/code/docs/circuitbreaker/DangerousJavaActor.java b/akka-docs/rst/common/code/docs/circuitbreaker/DangerousJavaActor.java index 23ad720d45..446d920dbe 100644 --- a/akka-docs/rst/common/code/docs/circuitbreaker/DangerousJavaActor.java +++ b/akka-docs/rst/common/code/docs/circuitbreaker/DangerousJavaActor.java @@ -51,17 +51,15 @@ public class DangerousJavaActor extends UntypedActor { if (message instanceof String) { String m = (String) message; if ("is my middle name".equals(m)) { - final Future f = future( - new Callable() { - public String call() { - return dangerousCall(); - } - }, getContext().dispatcher()); - pipe(breaker.callWithCircuitBreaker( new Callable>() { public Future call() throws Exception { - return f; + return future( + new Callable() { + public String call() { + return dangerousCall(); + } + }, getContext().dispatcher()); } }), getContext().dispatcher()).to(getSender()); }