code: def connection(self):
          
          heartbeat = self.container.config.get(
              HEARTBEAT_CONFIG_KEY, DEFAULT_HEARTBEAT
          )
          transport_options = self.container.config.get(
              TRANSPORT_OPTIONS_CONFIG_KEY, DEFAULT_TRANSPORT_OPTIONS
          )
          ssl = self.container.config.get(AMQP_SSL_CONFIG_KEY)
          conn = Connection(self.amqp_uri,
                            transport_options=transport_options,
                            heartbeat=heartbeat,
                            ssl=ssl
                            )
  
          return conn
docs: Provide the connection parameters for kombu's ConsumerMixin.
  
          The `Connection` object is a declaration of connection parameters
          that is lazily evaluated. It doesn't represent an established
          connection to the broker at this point.