def test_revive(self, n='test_revive'):
    c = compat.Consumer(self.connection, queue=n, exchange=n)
    with self.connection.channel() as c2:
        c.revive(c2)
        self.assertIs(c.backend, c2)
def test_revive(self, n='test_revive'):
    c = compat.Consumer(self.connection, queue=n, exchange=n)
    with self.connection.channel() as c2:
        c.revive(c2)
        self.assertIs(c.backend, c2)