使用用户定义的类使用rabbitmq队列中的xml消息。

rabbitmq-consume的Python项目详细描述


rabbitmq_consume项目

rabbitmq_consume项目包含rabbitmq_consume包,该包提供一个简单的Consumer类,用于处理来自rabbitmq队列的消息,rmq-consume该类是可用于运行该类的可执行文件,以及rmq-inject该cna用于将消息注入原始rabbitmq队列。

rmq-consume可执行文件

有关rmq-consume可执行文件的更多详细信息,请使用其帮助选项

rmq-consume -h

典型用法如下:

rmq-consume <queue> <module>[.<class>]

其中,<queue>是应该使用xml消息的rabbitmq队列的名称,<class>是将实际处理消息的<module>python模块中的python类。如果在命令行中省略`.<;类>;,则将使用其名称与模块名称匹配的类。

“consumption”类需要从Consumption.Consumption派生,如下例所示。

from Consumption import Consumption

class TrivialConsumption(Consumption):

    def __init__(self,
                 properties,
                 body,
                 redelivered):

    def consume(self):
        pass

大多数实际实现将保存propertiesbodyredelivered参数,以便在consume方法中使用。

rmq-inject可执行文件

有关rmq-inject可执行文件的更多详细信息,请使用其帮助选项

rmq-inject -h

典型用法如下:

rmq-inject -l <queue>

这将向队列中注入“停止侦听消息”,当消费者遇到此消息时,它将停止侦听更多消息并关闭。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
如何在Java和Javascript之间共享常量   c#无法使用Gson反序列化字节[]   如果字符串是实十进制数字,则在Java中仅显示十进制数字   与Android Studio的java FireBase同步失败   web应用程序的Java Oracle数据库更改通知问题   数组中缺少整数的java嵌套循环   zos在z/os上以TOD格式(一天中的时间)转换Java时间戳   java JAXB未根据注释生成XML(JDK 1.7)   java使用Twitter4j和Geolocation查找在该地区发布推文的用户,但如何获取用户ID?   在Libgdx中实现简单运动模糊的java意外结果   java在Android数据库中插入另一个EditText值?   java标准偏差数组(我的算法错误)   java如何修复M1 Mac的Ant javascript标记?   java遍历树标记值的长度   java理解Springboot中的Cron,自动发送电子邮件   java如何将“Data.Json”文件从资产保存到内部存储器,然后将其用于读/写   java代码在编写FirstDuplicate方法时会遇到时间限制问题   java将HTML转换为PDF并将其添加到段落中   javascript css()未设置正文标记的背景属性