} catch (RejectedExecutionException e) {
LOG.error("The commit executor's queue is full - submit task was rejected. \n{}", executor, e);
return FluentFutures.immediateFailedFluentFuture(new TransactionCommitFailedException(
"Could not submit the commit task - the commit queue capacity has been exceeded.", e));
}
} catch (RejectedExecutionException e) {
LOG.error("The commit executor's queue is full - submit task was rejected. \n{}", executor, e);
return FluentFutures.immediateFailedFluentFuture(new TransactionCommitFailedException(
"Could not submit the commit task - the commit queue capacity has been exceeded.", e));
}