package edu.columbia.p2psip.fwdl;

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;

/**
 *
 * @author Alejandro Mesa
 */
public class MessageListener implements Runnable
{
    private int _port;

    public MessageListener(int port) {
        _port = port;
    }

    public void run() {
        listenForMessages();
    }

    private void listenForMessages()
    {
        System.out.println("Listening for messages ... ");

        try {
            TCPConnection conn = new TCPServerConnection(_port);
            conn.openConnection();

            while(true) {
                //Listen for incoming messages
                Socket s = ((TCPServerConnection)conn).listenForConnections();

                MessageHandler mh = new MessageHandler(s);
                Thread t = new Thread(mh);
                t.start();

            }
        } catch (IOException e) {
            System.out.println("Error while accepting incoming messges");
            e.printStackTrace();
            System.exit(1);
        }
    }
}