LOG.warn("Abort of transaction {} failed for cohort {}", txId, cohort, failure);
sender.tell(new Status.Failure(failure), getSelf());
}
}, MoreExecutors.directExecutor());
}
LOG.warn("Abort of transaction {} failed for cohort {}", txId, cohort, failure);
sender.tell(new Status.Failure(failure), getSelf());
}
}, MoreExecutors.directExecutor());
}