rabbitpy使用purge不生效

时间:2022-07-24
本文章向大家介绍rabbitpy使用purge不生效，主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。

需要等消费者确认或者指明了不确认才能使用这个命令，而不能直接使用

#! /usr/bin/env python3
# -*- coding:utf-8 -*
import rabbitpy
import sys

url = 'amqp://guest:guest@localhost:5672/%2F'
connecttion = rabbitpy.Connection(url)
channel = connecttion.channel()

queue = rabbitpy.Queue(channel,'example')
# print(message.properties)
# sys.exit(0)
# queue.purge()
# sys.exit(0)
while len(queue) > 0:
    message = queue.get(True)

    # print(message)
    # sys.exit(0)
    message.pprint()
    # print('message:')
    # print('ID: %s' % message.properties['message_id'])
    # print('Time: %s' % message.properties['timestamp'].isoformat())
    # print("Body:%s" % message.body)
    message.ack() #不确认的话purge()是不会生效的
print("hello")
queue.purge()

随机文章
本站知识点必读
最近更新