第 5 章 使用 API
如需更多信息,请参阅 AMQ Python API 参考 和 AMQ Python 示例套件。
5.1. 处理消息传递事件 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
AMQ Python 是异步事件驱动 API。要定义应用程序如何处理事件,用户在 MessagingHandler 类上实施回调方法。然后,这些方法称为网络活动或计时器触发新事件。
示例:处理消息传递事件
class ExampleHandler(MessagingHandler):
def on_start(self, event):
print("The container event loop has started")
def on_sendable(self, event):
print("A message can be sent")
def on_message(self, event):
print("A message is received")
这些只是几个常见案例事件。完整的集合记录在 API 引用 中。