第 9 章 消息发送
9.1. 发送消息
要发送消息,请覆盖 on_sendable
事件处理程序并调用 Sender.send()
方法。当 Sender
有足够的分数来发送至少一个信息时,sendable
事件会触发。
示例:发送消息
class ExampleHandler(MessagingHandler): def on_start(self, event): conn = event.container.connect("amqp://example.com") sender = event.container.create_sender(conn, "jobs") def on_sendable(self, event): message = Message("job-content") event.sender.send(message)
如需更多信息,请参阅 send.py 示例。