package christie.daemon;

import christie.datagear.command.Command;

public class OutboundTcpConnection extends Thread {

    Connection connection;

    public OutboundTcpConnection(Connection connection) {
        this.connection = connection;
    }

    public void run() {
        while (true) {
            try {
                Command cmd = connection.sendQueue.take();
                switch (cmd.type) {
                    case CLOSE:
                        connection.close();
                        return;
                    case FINISH:
                        System.exit(0);
                        return;
                    default:
                        break;
                }
                connection.write(cmd);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}