@property
    def connection(self):
        if self.amqp_uri is None:
            return   # don't cache a connection during introspection

        if self._connection is None:
            self._connection = Connection(self.amqp_uri)

        return self._connection
Kombu requirement
dataset/ETHPy150Open onefinestay/nameko/nameko/messaging.py/QueueConsumer.connection