private QueuedNotificationManagerMXBeanImpl notificationManagerStatsBean;
+ private volatile long dataSize = 0;
+
private final SimpleDateFormat sdf =
new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
+ private boolean followerInitialSyncStatus = false;
+
public ShardStats(final String shardName, final String mxBeanType) {
super(shardName, mxBeanType, JMX_CATEGORY_SHARD);
}
this.lastCommittedTransactionTime = lastCommittedTransactionTime;
}
+ public void setInMemoryJournalDataSize(long dataSize){
+ this.dataSize = dataSize;
+ }
+
+ @Override
+ public long getInMemoryJournalDataSize(){
+ return dataSize;
+ }
+
@Override
public ThreadExecutorStats getDataStoreExecutorStats() {
// FIXME: this particular thing does not work, as it really is DS-specific
public void setDataStore(final InMemoryDOMDataStore store) {
setNotificationManager(store.getDataChangeListenerNotificationManager());
}
+
+ public void setFollowerInitialSyncStatus(boolean followerInitialSyncStatus) {
+ this.followerInitialSyncStatus = followerInitialSyncStatus;
+ }
+
+ @Override
+ public boolean getFollowerInitialSyncStatus() {
+ return followerInitialSyncStatus;
+ }
}