クラス AbstractClientConnectionFactory

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory
実装されているすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、InitializingBean、ApplicationContextAware、ApplicationEventPublisherAware、Lifecycle、ComponentSourceAware、ExpressionCapable、ConnectionFactory、NamedComponent、ManageableLifecycle
既知の直属サブクラス
CachingClientConnectionFactory、FailoverClientConnectionFactory、TcpNetClientConnectionFactory、TcpNioClientConnectionFactory、ThreadAffinityClientConnectionFactory
public abstract class AbstractClientConnectionFactory extends AbstractConnectionFactory
クライアント接続ファクトリの抽象クラス。クライアント接続ファクトリは発信接続を確立します。
導入:
2.0
作成者:
Gary Russell, Artem Bilan, Trung Pham

  • コンストラクターの詳細

    • AbstractClientConnectionFactory

      public AbstractClientConnectionFactory(StringSE host, int port)
      ホストとポートへの接続を確立するファクトリを構築します。
      パラメーター:
      host - ザホスト。
      port - ポート。

  • メソッドの詳細

    • setConnectTimeout

      public void setConnectTimeout(int connectTimeout)
      接続タイムアウトを秒単位で設定します。デフォルトは 60 です。
      パラメーター:
      connectTimeout - タイムアウト。
      導入:
      5.2

    • getConnectTimeout

      protected DurationSE getConnectTimeout()

    • enableManualListenerRegistration

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

    • getConnectionTest

      @Nullable protected PredicateSE<TcpConnectionSupport> getConnectionTest()
      新しい接続をテストするために呼び出される PredicateSE を取得します。接続を受け入れるには true を返し、拒否を false に返します。
      戻り値:
      述語。
      導入:
      5.3

    • setConnectionTest

      public void setConnectionTest(@Nullable 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 - 接続。