使用用户定义的类使用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中使合并排序只使用(n/2+1)额外空间的算法   将随机整数作为唯一ID从java插入mysql   试图通过Maven添加MySQL连接器时的java阻碍   使用CDI从producer为HashMap注入java歧义   java如何解决htmlUnit WrapsDriver错误   使用Java插入段落和子段落的级别   java复选框和文本视图与空白对齐   在Javascript警报中显示Java列表值   java在EclipseLuna的maven项目中构建成功后如何运行   java Spring MVC 3.1请求头字符编码问题[UTF8]   java将DAO公开为web服务   java如何知道@RequestMapping的哪个参数被调用   java如何根据设备启用硬件加速   使用byaccj构建ast时出现java错误   pdf如何使用iText Java垂直显示段落中的内容   java Selenium与Apache Poi在Excel中保存错误消息   安卓gson。JsonSyntaxException:java。lang.illegalstate例外:   Flex应用程序中浏览器缩放的java问题