in saga-core-akka/src/main/java/org/apache/servicecomb/saga/core/actors/RequestActor.java [64:80]
private RequestActor(
RequestActorContext context,
SagaTask task,
SagaRequest request) {
this.context = context;
this.task = task;
this.request = request;
this.parentResponses = new ArrayList<>(request.parents().length);
this.compensatedChildren = new LinkedList<>();
this.aborted = onReceive(ignored -> {
}).build();
this.transacted = onReceive(task::compensate)
.match(CompensationRecoveryMessage.class, message -> getContext().become(aborted))
.build();
}