EMP コネクタの詳細
コネクタを使用することで、Java で CometD クライアントを作成し、Streaming API に登録する複雑さを隠すことができます。EMP コネクタのコンポーネントを詳しく見てみましょう。
EMP コネクタは Java 8 に基づいており、CometD バージョン 3.0.9 を使用します。コネクタは PushTopic と汎用ストリーミングをサポートします。また、ユーザ名とパスワードを使った認証および OAuth ベアラートークンを使った認証もサポートします。
認証
ユーザのログイン情報が login 関数に渡されます。その後、login 関数の戻り値が、メインコネクタクラスに渡されます。
OAuth 認証の場合は、BayeuxParameters コンストラクタを使用して BayeuxParameters クラスのメソッドを上書きし、トークンと URL を提供します。
イベントのリスン
イベントをリスンするために、コネクタはラムダ式の Java イベントを使用します。このステートメントは、受信した各イベント通知のイベントメッセージを出力します。このステートメントをトピックに登録するステートメントの前に配置します。
トピックへの登録
EmpConnector クラスは、接続と登録を開始するための機能を公開するメインクラスです。このクラスには、接続を作成する関数、トピックに登録する関数、登録をキャンセルする関数、接続を停止する関数が含まれています。
登録を終了するには、次の関数をコールします。