code: def publish(self, message):
          
          if self._stopping:
              return
          self._logger.info("publishing\t%s" % message)
          properties = pika.BasicProperties(content_type=self._content_type,
                                            delivery_mode=1)
  
          self._channel.basic_publish(self._exchange,
                                      self._routing_key,
                                      message,
                                      properties)
docs: If not stopping, publish a message to RabbitMQ.
  
          :param str message: The fully encoded message to publish