ConnectionThread.java

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package ConsoleApp;

import java.io.IOException;
import java.net.Socket;
import javaChat.Connection;

/**
 *
 * @author GL552JX
 */
public class ConnectionThread extends Thread {
    
    private Socket client;
    private Connection connection;
    
    public ConnectionThread(Socket newClient) throws IOException{
        this.client = newClient;
        connection = new Connection(client);
    }
    
    public void run(){
        try {
            connection.startChat(" Start The Chat ");
            System.out.println(" ---------------- ");
            System.out.println(" new cilent connected ");
            System.out.println(" client information ");
            System.out.println(connection.getClientInformation());
            
            String inputan;
            String message;
            while((inputan = connection.readStream()) != null && inputan.equals("Quit")){
                message = "Client " + connection.getIpClient() + "Said : " + inputan;
                System.out.println(message);
                connection.sendToAll(message);
            }
            
            message = "Client from IP : " + connection.getIpClient() + "Quit the chat room";
            System.out.println(message);
            connection.sendToAll(message);
            connection.disconnect();
        } catch (Exception e) {
            System.out.println("Error");
        }
    }
}