} else if (message.getClass().equals(AbortTransaction.SERIALIZABLE_CLASS)) {
abort(new AbortTransaction());
} else {
- throw new Exception ("Not recognized message received,message="+message);
+ unknownMessage(message);
}
}
Boolean canCommit = future.get();
sender.tell(new CanCommitTransactionReply(canCommit).toSerializable(), self);
} catch (InterruptedException | ExecutionException e) {
- log.error(e, "An exception happened when aborting");
+ log.error(e, "An exception happened when checking canCommit");
}
}
}, getContext().dispatcher());