public ClientConnection(String host,
    int port) throws IOException 
{
	
        int proto_result = -1;
        fStubs = new ClientStubTable(this);
        m_dispatchers = new Dispatcher[2];
        m_dispatchers[0] = new DebuggerDispatcher(this);
        m_dispatchers[1] = new JsCallbacksDispatcher(this);
        fSocket = new Socket(host, port);
        fInputStream = fSocket.getInputStream();
        fDataInputStream = new DataInputStream(fInputStream);
        fOutputStream = fSocket.getOutputStream();
        fDataOutputStream = new DataOutputStream(fOutputStream);
        fDataOutputStream.writeInt(DebugConstants.BSF_DEBUG_PROTOCOL_MAJOR);
        fDataOutputStream.writeInt(DebugConstants.BSF_DEBUG_PROTOCOL_MINOR);
        proto_result = fDataInputStream.readInt();
        if (proto_result == DebugConstants.BSF_DEBUG_PROTOCOL_REJECT) {
            fSocket.close();
            fSocket = null;
            throw new ProtocolException("Protocol version mismatch.");
        }
        else {
            fThread = new Thread(this, "Socket Listener");
            fThread.start();
            m_debugManager = new DebugManagerStub(this);
        }
}

 public  void breakConnection() 
{
        try {
            m_debugManager.sendQuitNotice();
        }
        catch (Exception ex) {
            // Ignore. Means we were already disconnected.
        }
        stopListening();
        try {
            // Try to close down the socket ASAP. Otherwise, CPU gets chewed
            // in a loop.
            fSocket.setSoLinger(false, 0);
            fSocket.shutdownInput();
            fSocket.close();
            fSocket = null;
        }
        catch (IOException ioe) {
            // Socket must already be closed, or is otherwise unreadable
        }
}

 protected  void dispatchInvocation(ResultCell rcell) throws Exception 
{
        Exception ex;
        switch(rcell.classId) { 
        case DebugConstants.BSF_DEBUGGER_TID:
            m_dispatchers[0].dispatch(rcell);
            break;
        case DebugConstants.JS_CALLBACKS_TID:			
            m_dispatchers[1].dispatch(rcell);
            break;
        default:
            throw new Error("Can't parse the invocation!");
        }
}

 public DebugManagerStub getDebugManager() 
{
        return m_debugManager;
}

 public  void run() 
{
        listen();
}

 protected  void wireExceptionNotify(Exception ex) 
{
        DebugLog.stdoutPrintln("Disconnected", DebugLog.BSF_LOG_L1);
        m_debugManager.disconnectNotify(ex);
        super.wireExceptionNotify(ex);
}