raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Added retry pattern #22276 (#23997)

Browse source
This commit is contained in:
Daniel Kalman 2018-03-26 14:56:20 +03:00 • committed by Patrik Nordwall
parent 46c662965f
commit 86e44167f3
7 changed files with 245 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

29
akka-docs/src/test/java/jdocs/future/FutureDocTest.java
View file

@ -7,6 +7,7 @@ package jdocs.future;
//#imports1
import akka.dispatch.*;
import jdocs.AbstractJavaTest;
import scala.Function0;
import scala.concurrent.ExecutionContext;
import scala.concurrent.Future;
import scala.concurrent.Await;
@ -19,7 +20,9 @@ import akka.util.Timeout;
//#imports2
import scala.concurrent.duration.Duration;
import akka.japi.Function;
import java.util.concurrent.Callable;
import java.util.concurrent.*;
import static akka.dispatch.Futures.future;
import static java.util.concurrent.TimeUnit.SECONDS;
@ -58,13 +61,15 @@ import static akka.pattern.Patterns.after;
import java.util.Arrays;
//#imports7
//#imports8
import static akka.pattern.PatternsCS.retry;
//#imports8
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.CountDownLatch;
import scala.compat.java8.FutureConverters;
@ -541,6 +546,18 @@ public class FutureDocTest extends AbstractJavaTest {
Await.result(result, Duration.create(2, SECONDS));
}
@Test
public void useRetry() throws Exception {
//#retry
final ExecutionContext ec = system.dispatcher();
Callable<CompletionStage<String>> attempt = () -> CompletableFuture.completedFuture("test");
CompletionStage<String> retriedFuture = retry(attempt, 3, Duration.create(200, "millis"), system.scheduler(), ec);
//#retry
retriedFuture.toCompletableFuture().get(2, SECONDS);
}
@Test
public void thenApplyCompletionThread() throws Exception {
//#apply-completion-thread