コンストラクターの詳細

• AbstractClientConnectionFactory

  public AbstractClientConnectionFactory(StringSE host,
                                         int port)

  ホストとポートへの接続を確立するファクトリを構築します。

  パラメーター:

  host - ザホスト。

  port - ポート。

メソッドの詳細

• setConnectTimeout

  public void setConnectTimeout(int connectTimeout)

  接続タイムアウトを秒単位で設定します。デフォルトは 60 です。

  パラメーター:

  connectTimeout - タイムアウト。

  導入:

  5.2

• getConnectTimeout

  protected java.time.Duration getConnectTimeout()

• enableManualListenerRegistration

  public void enableManualListenerRegistration()

  このファクトリによって作成された接続に自動的に（デフォルト）または TcpListener を追加するかどうかを設定します。デフォルトでは、ファクトリはリスナーを自動的に構成します。手動登録が行われると、リスナーが登録されるまで受信メッセージが遅延します。

  導入:

  1.4.5

• getConnectionTest

  @Nullable
  protected java.util.function.PredicateSE<TcpConnectionSupport> getConnectionTest()

  新しい接続をテストするために呼び出される PredicateSE を取得します。接続を受け入れるには true を返し、拒否を false に返します。

  戻り値:

  述語。

  導入:

  5.3

• setConnectionTest

  public void setConnectionTest(@Nullable
                                java.util.function.PredicateSE<TcpConnectionSupport> connectionTest)

  新しい接続をテストするために呼び出される PredicateSE を設定します。接続を受け入れるには true を返し、拒否を false に返します。

  パラメーター:

  connectionTest - 述語。

  導入:

  5.3

• getConnection

  public TcpConnectionSupport getConnection()
                                     throws InterruptedExceptionSE

  接続を取得します。AbstractConnectionFactory.setSingleUse(boolean) が true で呼び出された場合、新しい接続が返されます。そうでない場合は、接続が開いたままである間、すべてのリクエストに対して単一の接続が再利用されます。

  例外:

  InterruptedExceptionSE - 中断された場合。

• obtainConnection

  protected TcpConnectionSupport obtainConnection()
                                           throws InterruptedExceptionSE

  例外:

  InterruptedExceptionSE

• obtainSharedConnection

  @Nullable
  protected final TcpConnectionSupport obtainSharedConnection()
                                                                 throws InterruptedExceptionSE

  例外:

  InterruptedExceptionSE

• obtainNewConnection

  protected final TcpConnectionSupport obtainNewConnection()
                                                    throws InterruptedExceptionSE

  例外:

  InterruptedExceptionSE

• buildNewConnection

  protected TcpConnectionSupport buildNewConnection()

• initializeConnection

  protected void initializeConnection(TcpConnectionSupport connection,
                                      SocketSE socket)

  (デ) シリアライザ、singleUse などの属性を新しい接続に転送します。接続ファクトリに TCPListener (レスポンスの読み取り用) への参照がある場合、または単一使用の接続の場合、接続が実行されます。単一使用の接続では、ソケットのタイムアウト後に接続を閉じるために、接続から読み取る必要があります。

  パラメーター:

  connection - 新しい接続。

  socket - 新しいソケット。

• setTheConnection

  protected void setTheConnection(TcpConnectionSupport theConnection)

  パラメーター:

  theConnection - 設定する theConnection

• getTheConnection

  @Nullable
  protected TcpConnectionSupport getTheConnection()

  戻り値:

  theConnection

• forceClose

  public void forceClose(TcpConnection connection)

  接続を強制的に閉じ、共有接続の場合はフィールドを null にします。

  パラメーター:

  connection - 接続。