             _messageHandler.setMessageListener(ErrorResponse, handleError);
             _messageHandler.setMessageListener(ReadyForQuery, handleFirstRfq);
 
-
             _broker.send(new StartupMessage(_params));
         }
 

            if (_authenticated) {
                _connecting = false;
                _connected = true;
                _rfq = true;
                _status = msg.status;

                _messageHandler.setMessageListener(ReadyForQuery, handleRfq);
                _messageHandler.setMessageListener(AuthenticationRequest, handleUnexpectedMessage);

                _messageHandler.setMessageListener(CommandComplete, handleComplete);
                _messageHandler.setMessageListener(EmptyQueryResponse, handleEmpty);

                _connHandler.handleConnected();
                handleRfq(msg);
            } else {
                throw new ProtocolError("Unexpected ReadyForQuery without AuthenticationOK"); 
            }
