appheartbeatmgmtimpl.java

中兴公司在parlayx开发方面的培训文档

package samples.fw;

public class AppHeartBeatMgmtImpl 
	extends org.csapi.fw.fw_application.integrity.IpAppHeartBeatMgmtPOA
{
    int interval;
    java.util.TimerTask pulser2FW;
    org.csapi.fw.fw_application.integrity.IpHeartBeat fwHeartBeat;

	public AppHeartBeatMgmtImpl(){
          heartbeatThread = new HeartbeatThread();
    }

	public void enableAppHeartBeat(int anInterval,
            org.csapi.fw.fw_application.integrity.IpHeartBeat aFwInterface)
    {
            interval = anInterval;
            fwInterface =  aFwInterface;
            schedule();
    }

	public void disableAppHeartBeat()
    {
    	pulser2FW.cancel();
    }

	public void changeInterval (int newInterval)
    {
          if (newInterval==interval)
            return;
          interval = newInterval;
          pulser2FW.cancel();
          pulser2FW = null;
          schedule();
    }

    void schedule()
	{
		pulser2FW = (new java.util.TimerTask()  {
                        public void run()
                        {
                                try{
                                	fwHeartBeat.pulse();
                                }catch(Exception e){
                                        if (AppFWImpl.LogWriter.isLoggable(logLevel.ERROR)) AppFWImpl.LogWriter.error("",e);
                                }
                        }
                });
		AppFWImpl.timer.scheduleAtFixedRate(pulser2FW, 0, interval);
	}
}