jay zé

import java.net.Socket;

/**
 * Created by E155059S on 23/03/17.
 */
public class Notifyer implements Runnable{

    private Client client;

    public Notifyer(Client client){
        this.client = client;
    }

    @Override
    public void run() {
        while(true){
            try {
                Thread.sleep(30000);
                System.out.println("notify");
                String message = "arrival:"+client.getHashCode()+"/"+client.getIpAddress();
                System.out.println(message);
                client.initCircle(message,client.getSuccessorIp());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }


    }
}