code: def _authenticate(self, client):
          
          yield client.authenticate(
              self._username, self._password, mechanism=self._auth_mechanism)
          returnValue(client)
docs: Perform AMQP authentication.