code: def channel(self):
          
          channel = getattr(self.state, "channel", None)
          if channel is None:
              channel = self.state.channel = self.connection.channel()
              if self.confirm_delivery:
                  channel.confirm_delivery()
  
              self.channels.add(channel)
          return channel
docs: The :class:`pika.BlockingChannel` for the current thread.
          This property may change without notice.