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);
		}
	}
}