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