@property
    def connection(self):
        try:
            return self.channel.connection.client
        except __HOLE__:
            pass
dataset/ETHPy150Open celery/kombu/kombu/messaging.py/Consumer.connection