job_queue.py 文件源码

def produce(self, message):
        """Publish a message to add inside the queue.

        Args;
            message: object to add inside the queue.
        """
        self.channel.basic_publish(exchange='',
                                   routing_key='dazzar_jobs',
                                   body=pickle.dumps(message),
                                   properties=pika.BasicProperties(
                                       delivery_mode=2,  # make message persistent
                                   ))