ConfigSyncCheck.java
693 Bytes
package com.sitech.jmx.mbean;
import com.sitech.ismp.messageObject.AgentSyncObject;
import com.sitech.schedule.ScheduleCache;
import com.sitech.schedule.Scheduler;
/**
* 检查采集配置是否已经同步
* @author linxc
* @version
* @since Ver 7.0.0
* @Date 2012 Jun 5, 2012 1:42:08 PM
*/
public class ConfigSyncCheck implements ConfigSyncCheckMBean {
public boolean isSynced(AgentSyncObject cfg) {
Scheduler scheduler = new Scheduler(cfg);
String scheduleId = scheduler.getScheduleId();
Scheduler schedulerMem = ScheduleCache.getScheduler(scheduleId);
if (schedulerMem == null) {
return false;
} else {
return schedulerMem.equals(scheduler);
}
}
}