package samples.fw;

public class AppHeartBeatImpl 
	extends org.csapi.fw.fw_application.integrity.IpAppHeartBeatPOA
{
	int interval;
    int raiseFaultInterval;
    long lastPulseTime;
	java.util.TimerTask fwWatcher;
	
	public AppHeartBeatImpl(int millis){
            interval = millis;
            raiseFaultInterval = 2*interval;
            schedule();
            lastPulseTime = System.currentTimeMillis() + interval;
    }

	public void pulse () {
    	lastPulseTime = System.currentTimeMillis();
    }

	public void schedule()
	{
		fwWatcher = (new java.util.TimerTask() {
                      public void run()
                      {
                          if ((System.currentTimeMillis()-lastPulseTime) >= raiseFaultInterval) {
                              System.out.println("AppHeartBeatImpl::did not get heart beat from Framework Server for:"+(raiseFaultInterval/1000)+" secons");
                          }
                      }
                });
		TheApplication.timer.schedule(fwWatcher, interval, raiseFaultInterval);
	}
}