TransactionIdentifier txId = message.getTxId();
ListenableFuture<S> future = process(handledMessageType.cast(message));
Executor callbackExecutor = future.isDone() ? MoreExecutors.directExecutor()
- : runnable -> executeInSelf(runnable);
+ : DataTreeCohortActor.this::executeInSelf;
Futures.addCallback(future, new FutureCallback<S>() {
@Override
public void onSuccess(S nextStep) {
@Override
ListenableFuture<PostCanCommitStep> process(CanCommit message) {
- return cohort.canCommit(message.getTxId(), message.getCandidates(), message.getSchema());
+ return cohort.canCommit(message.getTxId(), message.getSchema(), message.getCandidates());
}
@Override