使用用户定义的类使用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如何将JButton合并到图形中?   java在每个循环中使用基类类型或派生类类型   JavaSwingGUI应用程序完全是空白的,没有任何内容,而按钮被添加到面板中   java Android获取getDefaultSensor括号时出错   java Spring引导和安全性与AngularJS登录页面   java注销appengine应用程序而不从google注销。通用域名格式   java仅在发生错误或异常时创建日志文件,而不使用log4j   java get json数组和Retrift 2   swing中的java响应映像   为什么java的inputstream。close()块?   java驱动管理器。getConnection()非常冗长   java如何使用joml将标准化向量旋转到一个点   ubuntu将Java程序的输出结果保存到一个文件中   java动态可拖动、可编辑和自动调整大小的文本字段