code: def publish(self, channel, message, pipeline=False):
          
          if pipeline:
              self._pipeline.publish(channel, message)
          else:
              self._db.publish(channel, message)
docs: Post a message to a given channel.
  
          Args:
              channel (str): Channel where the message will be published
              message (str): Message to publish
              pipeline (bool): True, start a transaction block. Default false.