EMP コネクタの詳細

認証

LoginExample クラスは、デフォルトで、渡されたユーザーログイン情報を使用して本番組織にログインします。

初期認証の後、LoginExample は、認証が無効になった場合 (Salesforce セッションが無効になった場合やアクセストークンが取り消された場合など) に再認証を行います。LoginExample は、認証が有効でなくなったときにストリーミング API が送信する 401::Authentication invalid エラーメッセージをリスンします。401 エラーを受信すると、このクラスは再認証を行います。トークンプロバイダーは再認証を実行し、EmpConnector.setBearerTokenProvider() メソッドを使用して設定されます。

OAuth 認証の場合は、BearerTokenExample は、BayeuxParameters コンストラクターを使用して BayeuxParameters クラスのメソッドを上書きし、トークンと URL の値を提供します。

イベントのリスン

イベントをリスンするために、コネクタはラムダ式の Java イベントを使用します。このステートメントは、受信した各イベント通知のイベントメッセージを出力します。このステートメントをチャネルに登録するステートメントの前に配置します。

チャネルへの登録

EmpConnector クラスは、接続と登録を開始するための機能を公開するメインクラスです。このクラスには、接続を作成する関数、チャネルに登録する関数、登録をキャンセルする関数、接続を停止する関数が含まれています。

登録を終了するには、次の関数をコールします。

デバッグログ

デバッグを支援するため、LoggingListener クラスは Bayeux メッセージをコンソールに記録します。BearerTokenExample および DevLoginExample はログを使用しますが、LoginExample は使用しません。DevLoginExample は、EMP コネクタ GitHub プロジェクトの一部ですが、このウォークスルーでは取り上げません。詳細については、EMP コネクタの Readme ページを参照してください。