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