第9章 メッセージ配信
9.1. メッセージの送信
メッセージを送信するには、on_sendable
イベントハンドラーを上書きし、Sender.send()
メソッドを呼び出します。sendable
イベントは、Sender
が少なくとも 1 つのメッセージを送信するのに十分なクレジットがあると実行されます。
例: メッセージの送信
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 の例を参照してください。