メソッドの詳細

• register

  void register(ConsumerSE<InboundSseEvent> onEvent)

  InboundSseEvent コンシューマーを登録します。

  特定のコンシューマーは、受信したイベントごとに 1 回呼び出されます。

  パラメーター:

  onEvent - イベントのコンシューマー。

  例外:

  IllegalArgumentExceptionSE - 提供されたパラメーターが null の場合。

• register

  void register(ConsumerSE<InboundSseEvent> onEvent,
                ConsumerSE<ThrowableSE> onError)

  InboundSseEvent および ThrowableSE コンシューマーを登録します。

  イベントコンシューマーは、受信したイベントごとに 1 回呼び出され、Throwable コンシューマーは、SseEventSource で検出された回復不能なエラーが発生したときに呼び出されます。

  パラメーター:

  onEvent - イベントのコンシューマー。

  onError - エラーコンシューマー。

  例外:

  IllegalArgumentExceptionSE - 提供されたパラメーターのいずれかが null の場合。

• register

  void register(ConsumerSE<InboundSseEvent> onEvent,
                ConsumerSE<ThrowableSE> onError,
                RunnableSE onComplete)

  InboundSseEvent および ThrowableSE コンシューマーと onComplete コールバックを登録します。

  イベントコンシューマーは、受信したイベントごとに 1 回呼び出され、Throwable コンシューマーは、SseEventSource で回復不能なエラーが発生すると呼び出され、onComplete コールバックは、受信するイベントがなくなったときに呼び出されます。

  パラメーター:

  onEvent - イベントのコンシューマー。

  onError - エラーコンシューマー。

  onComplete - onComplete ハンドラー。

  例外:

  IllegalArgumentExceptionSE - 提供されたパラメーターのいずれかが null の場合。

• target

  static SseEventSource.Builder target(WebTarget endpoint)

  新しく準備されたイベントソースインスタンスのさまざまなアスペクトを構成および微調整する便利な方法を提供する新しい event source builder を作成します。

  パラメーター:

  endpoint - SSE ストリーミングエンドポイント。null であってはなりません。

  戻り値:

  指定された SSE ストリーミングエンドポイントを指す新しいイベントソースインスタンスのビルダー。

  例外:

  NullPointerExceptionSE - 提供された Web ターゲットが null の場合。

• open

  void open()

  web target の基礎となる提供された SSE への接続を開き、受信 events の処理を開始します。

  例外:

  IllegalStateExceptionSE - イベントソースがすでに開かれている場合。

• isOpen

  boolean isOpen()

  このイベントソースインスタンスがすでに opened になっていることを確認してください。

  戻り値:

  このイベントソースが開いている場合は true、それ以外の場合は false。

• close

  default void close()

  このイベントソースを閉じます。

  このメソッドは、内部イベント処理タスクが完了するまで最大 5 秒待機します。

  次で指定:

  インターフェース AutoCloseableSE の closeSE 

• close

  boolean close(long timeout,
                TimeUnitSE unit)

  このイベントソースを閉じて、内部イベント処理タスクが指定された待機時間まで完了するのを待ちます。

  このメソッドは、シャットダウンリクエスト後にイベント処理タスクの実行が完了するまで、またはタイムアウトが発生するまで、現在のスレッドが中断されるまで、どちらか早い方でブロックします。

  イベント処理タスクの待機が中断された場合、このメソッドは false を返す前にスレッドの interruptSE フラグを復元します。

  パラメーター:

  timeout - 待機する最大時間。

  unit - タイムアウト引数の時間単位。

  戻り値:

  このエグゼキュータが終了した場合は true、終了前にタイムアウトが経過した場合、終了が中断された場合は false。