alpha/alpha-spec-saga-akka/src/main/java/org/apache/servicecomb/pack/alpha/spec/saga/akka/SagaActor.java [253:264]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            (event, data) -> {
              UpdateTxEventDomain domainEvent = new UpdateTxEventDomain(event);
              return stay().applying(domainEvent).andThen(exec(_data -> {
                self().tell(ComponsitedCheckEvent.builder()
                    .serviceName(event.getServiceName())
                    .instanceId(event.getInstanceId())
                    .globalTxId(event.getGlobalTxId())
                    .localTxId(event.getLocalTxId())
                    .parentTxId(event.getParentTxId())
                    .preState(TxState.COMPENSATED_FAILED)
                    .build(), self());
              }));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



alpha/alpha-spec-saga-akka/src/main/java/org/apache/servicecomb/pack/alpha/spec/saga/akka/SagaActor.java [267:278]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            (event, data) -> {
              UpdateTxEventDomain domainEvent = new UpdateTxEventDomain(event);
              return stay().applying(domainEvent).andThen(exec(_data -> {
                self().tell(ComponsitedCheckEvent.builder()
                    .serviceName(event.getServiceName())
                    .instanceId(event.getInstanceId())
                    .globalTxId(event.getGlobalTxId())
                    .localTxId(event.getLocalTxId())
                    .parentTxId(event.getParentTxId())
                    .preState(TxState.COMPENSATED_FAILED)
                    .build(), self());
              }));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -