クラス ReactorNettyClientRequestFactory

メソッドの詳細

• setConnectTimeout

  public void setConnectTimeout(int connectTimeout)

  基になる接続タイムアウトをミリ秒単位で設定します。値 0 は、無限のタイムアウトを指定します。

  デフォルトは 30 秒です。

  関連事項:

  • Transport.option(ChannelOption, Object)
  • ChannelOption.CONNECT_TIMEOUT_MILLIS

• setConnectTimeout

  public void setConnectTimeout(DurationSE connectTimeout)

  基になる接続タイムアウトをミリ秒単位で設定します。値 0 は、無限のタイムアウトを指定します。

  デフォルトは 30 秒です。

  関連事項:

  • Transport.option(ChannelOption, Object)
  • ChannelOption.CONNECT_TIMEOUT_MILLIS

• setReadTimeout

  public void setReadTimeout(long readTimeout)

  基になる読み取りタイムアウトをミリ秒単位で設定します。

  デフォルトは 10 秒です。

• setReadTimeout

  public void setReadTimeout(DurationSE readTimeout)

  基礎となる読み取りタイムアウトを Duration として設定します。

  デフォルトは 10 秒です。

• setExchangeTimeout

  public void setExchangeTimeout(long exchangeTimeout)

  HTTP 交換のタイムアウトをミリ秒単位で設定します。

  デフォルトは 30 秒です。

• setExchangeTimeout

  public void setExchangeTimeout(DurationSE exchangeTimeout)

  HTTP 交換のタイムアウトを設定します。

  デフォルトは 30 秒です。

• createRequest

  public ClientHttpRequest createRequest(URISE uri, HttpMethod httpMethod) throws IOExceptionSE

  インターフェースからコピーされた説明: ClientHttpRequestFactory

  指定された URI および HTTP メソッドの新しい ClientHttpRequest を作成します。

  返されたリクエストは、ClientHttpRequest.execute() を呼び出して書き込み、実行できます。

  次で指定:

  インターフェース ClientHttpRequestFactory の createRequest 

  パラメーター:

  uri - リクエストを作成する URI

  httpMethod - 実行する HTTP メソッド

  戻り値:

  作成されたリクエスト

  例外:

  IOExceptionSE - I/O エラーの場合

• start

  public void start()

  インターフェースからコピーされた説明: Lifecycle

  このコンポーネントを起動します。

  コンポーネントがすでに実行されている場合は、例外をスローしないでください。

  コンテナーの場合、これは適用されるすべてのコンポーネントに開始シグナルを伝播します。

  次で指定:

  インターフェース Lifecycle の start 

  関連事項:

  • SmartLifecycle.isAutoStartup()

• stop

  public void stop()

  インターフェースからコピーされた説明: Lifecycle

  このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。非同期停止動作が必要な場合は、SmartLifecycle とその stop(Runnable) バリアントの実装を検討してください。

  この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、Lifecycle Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。

  コンポーネントが実行されていない（まだ開始されていない）場合は、例外をスローしないでください。

  コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。

  次で指定:

  インターフェース Lifecycle の stop 

  関連事項:

  • SmartLifecycle.stop(Runnable)
  • DisposableBean.destroy()

• stop

  public final void stop(RunnableSE callback)

  インターフェースからコピーされた説明: SmartLifecycle

  Lifecycle コンポーネントが現在実行中の場合、停止する必要があることを示します。

  提供されたコールバックは、LifecycleProcessor によって使用され、共通のシャットダウン順序値を持つすべてのコンポーネントの順序付けられた、潜在的に同時のシャットダウンをサポートします。コールバック は、SmartLifecycle コンポーネントが実際に停止した後に実行する必要があります。

  LifecycleProcessor は、stop メソッドのこのバリアントのみを呼び出します。つまり、SmartLifecycle 実装では、このメソッドの実装内に明示的に委譲されない限り、Lifecycle.stop() は呼び出されません。

  デフォルトの実装は Lifecycle.stop() に委譲し、呼び出しスレッドで指定されたコールバックをすぐにトリガーします。2 つの間に同期がないことに注意してください。カスタム実装では、少なくとも共通のライフサイクルモニター（存在する場合）内に同じ手順を入れたい場合があります。

  次で指定:

  インターフェース SmartLifecycle の stop 

  関連事項:

  • Lifecycle.stop()
  • SmartLifecycle.getPhase()

• isRunning

  public boolean isRunning()

  インターフェースからコピーされた説明: Lifecycle

  このコンポーネントが現在実行されているかどうかを確認します。

  コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true を返します。

  次で指定:

  インターフェース Lifecycle の isRunning 

  戻り値:

  コンポーネントが現在実行中かどうか

• isAutoStartup

  public boolean isAutoStartup()

  インターフェースからコピーされた説明: SmartLifecycle

  true が含まれる ApplicationContext がリフレッシュされるときに、この Lifecycle コンポーネントがコンテナーによって自動的に開始される場合、true を返します。

  false の値は、プレーン Lifecycle 実装に類似した、明示的な Lifecycle.start() 呼び出しを介してコンポーネントが開始されることを意図していることを示します。

  デフォルトの実装は true を返します。

  次で指定:

  インターフェース SmartLifecycle の isAutoStartup 

  関連事項:

  • Lifecycle.start()
  • SmartLifecycle.getPhase()
  • LifecycleProcessor.onRefresh()
  • ConfigurableApplicationContext.refresh()

• getPhase

  public int getPhase()

  インターフェースからコピーされた説明: SmartLifecycle

  このライフサイクルオブジェクトが実行されるはずのフェーズを返します。

  デフォルトの実装は、通常の Lifecycle 実装の後に stop() コールバックを実行させるために、SmartLifecycle.DEFAULT_PHASE を返します。

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

  関連事項:

  • SmartLifecycle.isAutoStartup()
  • Lifecycle.start()
  • SmartLifecycle.stop(Runnable)
  • DefaultLifecycleProcessor.getPhase(Lifecycle)