in saga-core/src/main/java/org/apache/servicecomb/saga/core/BackwardRecovery.java [34:48]
public SagaResponse apply(SagaTask task, SagaRequest request, SagaResponse parentResponse) {
try {
return request.transaction().send(request.serviceName(), parentResponse);
} catch (Exception e) {
log.error("Applying {} policy due to failure in transaction {} of service {}",
description(),
request.transaction(),
request.serviceName(),
e
);
task.abort(request, e);
throw e;
}
}