             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.handleRfq();
                _connHandler.handleConnected();
            } else {
                throw new ProtocolError("Unexpected ReadyForQuery without AuthenticationOK"); 
            }

            _messageHandler.setMessageListener(ErrorResponse, handleError);
            _messageHandler.setMessageListener(ReadyForQuery, handleFirstRfq);

            _broker.send(new StartupMessage(_params));
        }

