fix java documentation snippet by being explicit (#24569)
* fix java documentation snippet by being explicit * Update FaultHandlingTest.java * Update FaultHandlingTest.java * Update FaultHandlingTest.java
This commit is contained in:
parent
ba5f26f7bf
commit
8d1feb5a10
1 changed files with 13 additions and 13 deletions
|
|
@ -29,10 +29,7 @@ import scala.concurrent.Await;
|
|||
|
||||
//#supervisor
|
||||
import akka.japi.pf.DeciderBuilder;
|
||||
import static akka.actor.SupervisorStrategy.resume;
|
||||
import static akka.actor.SupervisorStrategy.restart;
|
||||
import static akka.actor.SupervisorStrategy.stop;
|
||||
import static akka.actor.SupervisorStrategy.escalate;
|
||||
import akka.actor.SupervisorStrategy;
|
||||
|
||||
//#supervisor
|
||||
|
||||
|
|
@ -57,11 +54,13 @@ public class FaultHandlingTest extends AbstractJavaTest {
|
|||
|
||||
//#strategy
|
||||
private static SupervisorStrategy strategy =
|
||||
new OneForOneStrategy(10, Duration.create(1, TimeUnit.MINUTES), DeciderBuilder.
|
||||
match(ArithmeticException.class, e -> resume()).
|
||||
match(NullPointerException.class, e -> restart()).
|
||||
match(IllegalArgumentException.class, e -> stop()).
|
||||
matchAny(o -> escalate()).build());
|
||||
new OneForOneStrategy(10, Duration.create(1, TimeUnit.MINUTES),
|
||||
DeciderBuilder
|
||||
.match(ArithmeticException.class, e -> SupervisorStrategy.resume())
|
||||
.match(NullPointerException.class, e -> SupervisorStrategy.restart())
|
||||
.match(IllegalArgumentException.class, e -> SupervisorStrategy.stop())
|
||||
.matchAny(o -> SupervisorStrategy.escalate())
|
||||
.build());
|
||||
|
||||
@Override
|
||||
public SupervisorStrategy supervisorStrategy() {
|
||||
|
|
@ -89,10 +88,11 @@ public class FaultHandlingTest extends AbstractJavaTest {
|
|||
//#strategy2
|
||||
private static SupervisorStrategy strategy =
|
||||
new OneForOneStrategy(10, Duration.create(1, TimeUnit.MINUTES), DeciderBuilder.
|
||||
match(ArithmeticException.class, e -> resume()).
|
||||
match(NullPointerException.class, e -> restart()).
|
||||
match(IllegalArgumentException.class, e -> stop()).
|
||||
matchAny(o -> escalate()).build());
|
||||
match(ArithmeticException.class, e -> SupervisorStrategy.resume()).
|
||||
match(NullPointerException.class, e -> SupervisorStrategy.restart()).
|
||||
match(IllegalArgumentException.class, e -> SupervisorStrategy.stop()).
|
||||
matchAny(o -> SupervisorStrategy.escalate())
|
||||
.build());
|
||||
|
||||
@Override
|
||||
public SupervisorStrategy supervisorStrategy() {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue