前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >rabbitpy使用purge不生效

rabbitpy使用purge不生效

作者头像
槽痞
发布2020-09-15 10:30:41
1.6K0
发布2020-09-15 10:30:41
举报

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

#! /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()
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2020-09-11,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档