queue.py 文件源码

def publish(self, msg):
        try:
            self._channel.basic_publish(exchange=self._exchange, routing_key=self._qname, body=msg)

        except pika.exceptions.AMQPError as e:
            raise PipelineQueueError("Couldn't push message to queue: {reason}".format(reason=e))