Shard.this.persistData(getSender(), transactionID,
new ModificationPayload(cohortEntry.getModification()));
}
Shard.this.persistData(getSender(), transactionID,
new ModificationPayload(cohortEntry.getModification()));
}
LOG.error(e, "{} An exception occurred while preCommitting transaction {}",
persistenceId(), cohortEntry.getTransactionID());
shardMBean.incrementFailedTransactionsCount();
LOG.error(e, "{} An exception occurred while preCommitting transaction {}",
persistenceId(), cohortEntry.getTransactionID());
shardMBean.incrementFailedTransactionsCount();
shardMBean.incrementCommittedTransactionCount();
shardMBean.setLastCommittedTransactionTime(System.currentTimeMillis());
shardMBean.incrementCommittedTransactionCount();
shardMBean.setLastCommittedTransactionTime(System.currentTimeMillis());
sender.tell(new akka.actor.Status.Failure(e), getSelf());
LOG.error(e, "{}, An exception occurred while committing transaction {}", persistenceId(), transactionID);
shardMBean.incrementFailedTransactionsCount();
sender.tell(new akka.actor.Status.Failure(e), getSelf());
LOG.error(e, "{}, An exception occurred while committing transaction {}", persistenceId(), transactionID);
shardMBean.incrementFailedTransactionsCount();