import org.opendaylight.controller.cluster.datastore.jmx.mbeans.AbstractBaseMBean;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
/**
* @author: syedbahm
*/
private Long lastApplied = -1L;
+ private Date lastCommittedTransactionTime = new Date(0L);
+
+ private Long failedTransactionsCount = 0L;
+
+ private SimpleDateFormat sdf =
+ new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
+
ShardStats(String shardName) {
this.shardName = shardName;
}
return lastApplied;
}
+ @Override
+ public String getLastCommittedTransactionTime() {
+
+ return sdf.format(lastCommittedTransactionTime);
+ }
+
+ @Override public Long getFailedTransactionsCount() {
+ return failedTransactionsCount;
+ }
+
public Long incrementCommittedTransactionCount() {
return committedTransactionsCount++;
}
this.lastApplied = lastApplied;
}
+
+ public void setLastCommittedTransactionTime(
+ Date lastCommittedTransactionTime) {
+ this.lastCommittedTransactionTime = lastCommittedTransactionTime;
+ }
+
@Override
protected String getMBeanName() {
return shardName;
}
+ public void incrementFailedTransactionsCount() {
+ this.failedTransactionsCount++;
+ }
}