my_rabbitmq.py 文件源码

def put_queue_list(self, queue_name=None, message_list=None):
        """put queue to list"""
        if not queue_name:
            return None
        try:
            if not message_list:
                return None
            if isinstance(message_list, dict):
                message_list = [message_list]
            self.__connect()
            self.channel.queue_declare(queue=queue_name, durable=True)
            for message in message_list:
                message = json.dumps(message)
                self.channel.basic_publish(
                    exchange='',
                    routing_key=queue_name,
                    body=message,
                    properties=pika.BasicProperties(delivery_mode=2, ))
            self.connection.close()
        except Exception as e:
            print e
            return None