import java.io.IOException;
import java.net.InetSocketAddress;


public class ArrivalTest {
    public static void main(String[] args)
    {

        MulticastQueue<Integer> server = startServer(44400);
        MulticastQueue<Integer> client1 = startClient(44401, 44400);
        MulticastQueue<Integer> client2 = startClient(44402, 44400);
        MulticastQueue<Integer> client3 = startClient(44403, 44400);
        MulticastQueue<Integer> client4 = startClient(44404, 44400);


        Thread t1 = new Thread(new Getter(server, "server")); t1.start();
        Thread t2 = new Thread(new Getter(client1, "client1")); t2.start();
        Thread t3 = new Thread(new Getter(client2, "client2")); t3.start();
        Thread t4 = new Thread(new Getter(client3, "client3")); t4.start();
        Thread t5 = new Thread(new Getter(client4, "client4")); t5.start();

        try {
            Thread.sleep(2000);
        } catch (InterruptedException e1) {
            e1.printStackTrace();
        }

        client1.put(1);
        client2.put(2);
        client3.put(3);
        client4.put(4);
        client1.put(5);
        /*client2.put(6);
        client2.put(7);
        client2.put(8);
        client3.put(9);
        client3.put(10);
        client1.put(11);
        client1.put(12);
        client2.put(13);
        client3.put(14);
        client2.put(15);*/

    }

    private static MulticastQueue<Integer> startServer(int localPort)
    {
        MulticastQueue<Integer> peer = new MulticastQueueTotal<Integer>();
        try {
            peer.createGroup(localPort, MulticastQueue.DeliveryGuarantee.TOTAL);
        } catch (IOException e) {
            System.err.println("Cannot start server: " + e.getMessage());
            System.exit(-1);
        }
        //System.out.println("== Starting server on "+localPort);
        return peer;
    }
    private static MulticastQueue<Integer> startClient(int localPort, int serverPort)
    {
        MulticastQueue<Integer> peer = new MulticastQueueTotal<Integer>();
        try {
            peer.joinGroup(localPort, new InetSocketAddress("localhost", serverPort),
                    MulticastQueue.DeliveryGuarantee.TOTAL);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //System.out.println("== Starting client on: "+localPort);
        return peer;
    }
}