From 3b9ed6ac03e51f35154f62447c87c8f4d42d0e84 Mon Sep 17 00:00:00 2001 From: gfaerie Date: Thu, 3 Jul 2014 18:41:58 +0200 Subject: [PATCH] =doc #15491 java circuit breaker doc update --- .../docs/circuitbreaker/DangerousJavaActor.java | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) 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()); }