3 public class HeartBeatSNode extends Thread {
6 public static HeartBeatSNode Instance;
8 private JaceSuperNodeInterface server = null;
15 private HeartBeatSNode() {
18 public static HeartBeatSNode Instance() {
19 if (Instance == null) {
20 Instance = new HeartBeatSNode();
25 public void setHeartTime(int timeBeat) {
29 public int getHeartTime() {
33 public void setServer(JaceSuperNodeInterface serverEntity) {
34 server = serverEntity;
36 // JaceBuffer.Instance().purge();
37 // MsgQueue.Instance().purge();
41 public JaceSuperNodeInterface getServer() {
51 // each "time" milisecondes, get the register if it has changed
53 // System.out.println("sleeping for "+beat);
54 // time = System.currentTimeMillis();
56 server.beating(TokenThread.Instance().getToken());
60 } catch (Exception e) {