gistfile1.txt

    def prepareExchanges(self, conn):

        log.msg("preparing")
        self._chan = conn.channel(1)

        self._chan = self._chan.addCallback(lambda c: c.channel_open())

        res = self._chan.addCallback(lambda c: c.exchange_declare(exchange=self._exchange, type="direct", durable=True, auto_delete=False))

        return res



        
    deferred = client.authenticate(self.user, self.password)
    self._conn = deferred
    deferred = deferred.addCallback(self.prepareExchanges)
    deferred = deferred.addCallback(self.associateConnectionWithBots)
    return deferred