@Override
	public void run() {
		while (true) {
			try {
				JobMessage msg = new JobMessage("status", job, toHost, toPort);
				Message ret = commModule.send(msg);
				System.out.println(ret.getContent());
				// wait for some interval until the next heart beat
				Thread.sleep(sleepInterval);
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (RemoteException e) {
				retryCount++;
				// recognizing the master is not there, it the slave aborts
				if (retryCount > retryNum) {
					System.out
							.println("Coordinator not responding. Job Fail");
					System.exit(-1);
				}
				System.out.println("Coordinator not responding. Retry in "
						+ sleepInterval / 1000 + " seconds... (attempt "
						+ retryCount + "/" + retryNum + ")");
			}
		}

	}