return lastBatchedModificationsException;
}
+ @SuppressWarnings("checkstyle:IllegalCatch")
void applyModifications(final Iterable<Modification> modifications) {
totalBatchedModificationsReceived++;
- if(lastBatchedModificationsException == null) {
+ if (lastBatchedModificationsException == null) {
for (Modification modification : modifications) {
- try {
- modification.apply(transaction.getSnapshot());
- } catch (RuntimeException e) {
- lastBatchedModificationsException = e;
- throw e;
- }
+ try {
+ modification.apply(transaction.getSnapshot());
+ } catch (RuntimeException e) {
+ lastBatchedModificationsException = e;
+ throw e;
+ }
}
}
}
cohort = transaction.ready();
- if(cohortDecorator != null) {
+ if (cohortDecorator != null) {
// Call the hook for unit tests.
cohort = cohortDecorator.decorate(transactionID, cohort);
}
.append(doImmediateCommit).append("]");
return builder.toString();
}
-}
\ No newline at end of file
+}