Acceptor.java

public class Acceptor implements Runnable{

    private SelectionKey selectionKey;
    private ServerSocketChannel serverSocketChannel;
    private final Boolean isWithThreadPool;

    private final String sessionName = "Acceptor";
    private String sessionAdress;

    public Acceptor(final SelectionKey selectionKey, Boolean isWithThreadPool) throws IOException {
        this.selectionKey = selectionKey;
        this.serverSocketChannel = (ServerSocketChannel) selectionKey.channel();
        this.sessionAdress = serverSocketChannel.getLocalAddress().toString();
        this.isWithThreadPool = isWithThreadPool;
    }

    @Override
    public void run() {
        try {
            SocketChannel socketChannel = serverSocketChannel.accept();
            if (socketChannel != null) {
                if (isWithThreadPool) {
//                    new HandlerWithThreadPool(selector, socketChannel);
                    System.out.println("not implemented");
                }
                else {
                    new Handler(selectionKey.selector(), socketChannel);
                }
            }
            System.out.println("Connection Accepted by Command Center");
            System.out.println("New client ip=" + socketChannel.getRemoteAddress());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public String toString() {
        return sessionName + "@" + sessionAdress;
    }
}