This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch SCB-1321-cleanup in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit dbaed1e7904558dbc5ff0928aed2779d040541c8 Author: Willem Jiang <[email protected]> AuthorDate: Fri Jul 12 11:24:15 2019 +0800 SCB-1321 Polish the code of SagaActor --- .../main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java index 7b07d4e..cfa8eaa 100644 --- a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java +++ b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java @@ -21,6 +21,7 @@ import akka.actor.Props; import akka.persistence.fsm.AbstractPersistentFSM; import java.lang.invoke.MethodHandles; import java.util.Arrays; +import java.util.Collections; import java.util.Date; import java.util.concurrent.TimeUnit; import org.apache.servicecomb.pack.alpha.core.AlphaException; @@ -107,7 +108,7 @@ public class SagaActor extends .applying(domainEvent) .forMax(Duration.create(1, TimeUnit.MILLISECONDS)); } - ).event(Arrays.asList(StateTimeout()), SagaData.class, + ).event(Collections.singletonList(StateTimeout()), SagaData.class, (event, data) -> { SagaEndedDomain domainEvent = new SagaEndedDomain(null, SagaActorState.SUSPENDED); return goTo(SagaActorState.SUSPENDED) @@ -153,7 +154,7 @@ public class SagaActor extends return goTo(SagaActorState.FAILED) .applying(domainEvent); } - ).event(Arrays.asList(StateTimeout()), SagaData.class, + ).event(Collections.singletonList(StateTimeout()), SagaData.class, (event, data) -> { return goTo(SagaActorState.SUSPENDED) .forMax(Duration.create(1, TimeUnit.MILLISECONDS)); @@ -208,7 +209,7 @@ public class SagaActor extends UpdateTxEventDomain domainEvent = new UpdateTxEventDomain(event); return goTo(SagaActorState.FAILED).applying(domainEvent); } - ).event(Arrays.asList(StateTimeout()), SagaData.class, + ).event(Collections.singletonList(StateTimeout()), SagaData.class, (event, data) -> { return goTo(SagaActorState.SUSPENDED) .forMax(Duration.create(1, TimeUnit.MILLISECONDS));//.replying(data);
