メッセージングシステムを構築するのに便利な機能も存在します。サンプルを作成してみます。リポジトリにあげています。以下の依存ライブラリの情報を加えます。使用した簡単な処理は以下のようになります。簡単なサンプルを作成します。し、メッセージを受信するとログに吐き出しています。メッセージを受信した時点で処理を終了します。いう抽象クラスが用意されています。開始と終了、メッセージ受信時等のコールバックを実装します。いった概念が存在します。よるストリーミング処理を連携させるサンプルを作成します。↓メッセージ出力というようにしています。以下のようになります。作成することができます。その役目を任せています。