/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package gy2messages;

/**
 *
 * @author lengyel
 */
public class Reader implements Runnable {

    private Server server;
    private int delay;
    private String name;

    public Reader(String name, Server server, int delay) {
        this.server = server;
        this.delay = delay;
        this.name = name;
    }

    public void run() {
        while (true) {
            while (server.hasNoMessages()) {
            }
            Message msg = null;
//            msg = server.getLastMessage();
            synchronized (msg = server.getLastMessage()) {
                if (msg != null) {
                    System.out.println(name + " :: Message index: " + msg.getIdx());
                    for (String line : msg.lines) {
                        System.out.println(line);
                    }
                }
                try {
                    Thread.sleep(delay);
                } catch (InterruptedException ex) {
                    System.out.println(name + " quits");
                    return;
                }
            }
        }
    }
}