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 示例