第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 の例を参照してください。
