'Connect to the RabbitMQ broker'

def _adapter_connect(self):

    error = super(TwistedConnection, self)._adapter_connect()
    if (not error):
        self.ioloop.update_handler(None, self.event_state)
    return error
