使用用户定义的类使用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
大多数实际实现将保存properties
、body
和redelivered
参数,以便在consume
方法中使用。
rmq-inject
可执行文件
有关rmq-inject
可执行文件的更多详细信息,请使用其帮助选项
rmq-inject -h
典型用法如下:
rmq-inject -l <queue>
这将向队列中注入“停止侦听消息”,当消费者遇到此消息时,它将停止侦听更多消息并关闭。