9.3. 接收消息
要接收信息,创建一个接收器并覆盖 on_message
事件处理程序。
示例:接收消息
class ExampleHandler(MessagingHandler): def on_start(self, event): conn = event.container.connect("amqp://example.com") receiver = event.container.create_receiver(conn, "jobs") def on_message(self, event): print("Received message", event.message, "from", event.receiver)
如需更多信息,请参阅 receive .py 示例。