クラス CachingClientConnectionFactory

メソッドの詳細

• setConnectionWaitTimeout

  public void setConnectionWaitTimeout(int connectionWaitTimeout)

  パラメーター:

  connectionWaitTimeout - 新しいタイムアウト。

  関連事項:

  • SimplePool.setWaitTimeout(long)

• setPoolSize

  public void setPoolSize(int poolSize)

  パラメーター:

  poolSize - 新しいプールサイズ。

  関連事項:

  • SimplePool.setPoolSize(int)

• getPoolSize

  public int getPoolSize()

  戻り値:

  プールサイズ。

  関連事項:

  • SimplePool.getPoolSize()

• getIdleCount

  public int getIdleCount()

  戻り値:

  アイドルカウント。

  関連事項:

  • SimplePool.getIdleCount()

• getActiveCount

  public int getActiveCount()

  戻り値:

  アクティブなカウント。

  関連事項:

  • SimplePool.getActiveCount()

• getAllocatedCount

  public int getAllocatedCount()

  戻り値:

  割り当てられたカウント。

  関連事項:

  • SimplePool.getAllocatedCount()

• obtainConnection

  public TcpConnectionSupport obtainConnection()

  オーバーライド:

  クラス AbstractClientConnectionFactory の obtainConnection 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

  次で指定:

  インターフェース ManageableLifecycle の isRunning 

  オーバーライド:

  クラス AbstractConnectionFactory の isRunning 

• hashCode

  public int hashCode()

  オーバーライド:

  クラス ObjectSE の hashCode 

• setComponentName

  public void setComponentName(StringSE componentName)

  クラスからコピーされた説明: IntegrationObjectSupport

  このコンポーネントの名前を設定します。

  オーバーライド:

  クラス IntegrationObjectSupport の setComponentName 

  パラメーター:

  componentName - コンポーネント名。

• getComponentType

  public StringSE getComponentType()

  クラスからコピーされた説明: IntegrationObjectSupport

  サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。

  次で指定:

  インターフェース NamedComponent の getComponentType 

  オーバーライド:

  クラス IntegrationObjectSupport の getComponentType 

• equals

  public boolean equals(ObjectSE o)

  オーバーライド:

  クラス ObjectSE の equalsSE 

• getSoTimeout

  public int getSoTimeout()

  オーバーライド:

  クラス AbstractConnectionFactory の getSoTimeout 

  戻り値:

  soTimeout

• setSoTimeout

  public void setSoTimeout(int soTimeout)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoTimeout 

  パラメーター:

  soTimeout - 設定する soTimeout（ミリ秒単位）

• getSoReceiveBufferSize

  public int getSoReceiveBufferSize()

  オーバーライド:

  クラス AbstractConnectionFactory の getSoReceiveBufferSize 

  戻り値:

  soReceiveBufferSize

• setSoReceiveBufferSize

  public void setSoReceiveBufferSize(int soReceiveBufferSize)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoReceiveBufferSize 

  パラメーター:

  soReceiveBufferSize - 設定する soReceiveBufferSize

• getSoSendBufferSize

  public int getSoSendBufferSize()

  オーバーライド:

  クラス AbstractConnectionFactory の getSoSendBufferSize 

  戻り値:

  soSendBufferSize

• setSoSendBufferSize

  public void setSoSendBufferSize(int soSendBufferSize)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoSendBufferSize 

  パラメーター:

  soSendBufferSize - 設定する soSendBufferSize

• isSoTcpNoDelay

  public boolean isSoTcpNoDelay()

  オーバーライド:

  クラス AbstractConnectionFactory の isSoTcpNoDelay 

  戻り値:

  soTcpNoDelay

• setSoTcpNoDelay

  public void setSoTcpNoDelay(boolean soTcpNoDelay)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoTcpNoDelay 

  パラメーター:

  soTcpNoDelay - 設定する soTcpNoDelay

• getSoLinger

  public int getSoLinger()

  オーバーライド:

  クラス AbstractConnectionFactory の getSoLinger 

  戻り値:

  soLinger

• setSoLinger

  public void setSoLinger(int soLinger)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoLinger 

  パラメーター:

  soLinger - 設定する soLinger

• isSoKeepAlive

  public boolean isSoKeepAlive()

  オーバーライド:

  クラス AbstractConnectionFactory の isSoKeepAlive 

  戻り値:

  soKeepAlive

• setSoKeepAlive

  public void setSoKeepAlive(boolean soKeepAlive)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoKeepAlive 

  パラメーター:

  soKeepAlive - 設定する soKeepAlive

• getSoTrafficClass

  public int getSoTrafficClass()

  オーバーライド:

  クラス AbstractConnectionFactory の getSoTrafficClass 

  戻り値:

  soTrafficClass

• setSoTrafficClass

  public void setSoTrafficClass(int soTrafficClass)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoTrafficClass 

  パラメーター:

  soTrafficClass - 設定する soTrafficClass

• getHost

  public StringSE getHost()

  オーバーライド:

  クラス AbstractConnectionFactory の getHost 

  戻り値:

  ザホスト

• getPort

  public int getPort()

  オーバーライド:

  クラス AbstractConnectionFactory の getPort 

  戻り値:

  港

• getSender

  public TcpSender getSender()

  オーバーライド:

  クラス AbstractConnectionFactory の getSender 

  戻り値:

  存在する場合、最初の送信者。

• getSerializer

  public Serializer<?> getSerializer()

  オーバーライド:

  クラス AbstractConnectionFactory の getSerializer 

  戻り値:

  シリアライザー

• getDeserializer

  public Deserializer<?> getDeserializer()

  オーバーライド:

  クラス AbstractConnectionFactory の getDeserializer 

  戻り値:

  デシリアライザー

• getMapper

  public TcpMessageMapper getMapper()

  オーバーライド:

  クラス AbstractConnectionFactory の getMapper 

  戻り値:

  マッパー

• registerListener

  public void registerListener(TcpListener listener)

  データの受信に使用されるデリゲート TCP クライアント接続ファクトリには、メッセージを送信するリスナーが必要です。これは、送信ゲートウェイまたはコラボレーションチャネルアダプターのペアに使用されるクライアントファクトリに適用されます。

  初期化中に、ファクトリにリスナーがないことが検出されると、そのリスニングロジック（アクティブスレッド）は終了します。

  ファクトリに登録されたリスナーは、作成される各接続に提供されるため、onMessage() メソッドを呼び出すことができます。

  このコードは、このリスナーがリスニングロジックを実行する必要があることをファクトリに通知するという最初の要件を満たします。

  実際の接続を CachedConnections でラップすると、接続にはリスナーとしてラッパーが渡されるため、onMessage() のヘッダーを拡張できます。その後、ラッパーは変更されたメッセージを使用して、ここで提供される実際のリスナーを呼び出します。

  オーバーライド:

  クラス AbstractConnectionFactory の registerListener 

  パラメーター:

  listener - TcpListener。

• registerSender

  public void registerSender(TcpSender sender)

  クラスからコピーされた説明: AbstractConnectionFactory

  TcpSender を登録します。サーバーソケットの場合、接続情報を提供するために使用されるため、送信者は受信メッセージに返信するために使用できます。

  オーバーライド:

  クラス AbstractConnectionFactory の registerSender 

  パラメーター:

  sender - 送り主

• setTaskExecutor

  public void setTaskExecutor(ExecutorSE taskExecutor)

  オーバーライド:

  クラス AbstractConnectionFactory の setTaskExecutor 

  パラメーター:

  taskExecutor - 設定する taskExecutor

• setDeserializer

  public void setDeserializer(Deserializer<?> deserializer)

  オーバーライド:

  クラス AbstractConnectionFactory の setDeserializer 

  パラメーター:

  deserializer - 設定するデシリアライザー

• setSerializer

  public void setSerializer(Serializer<?> serializer)

  オーバーライド:

  クラス AbstractConnectionFactory の setSerializer 

  パラメーター:

  serializer - 設定するシリアライザー

• setMapper

  public void setMapper(TcpMessageMapper mapper)

  オーバーライド:

  クラス AbstractConnectionFactory の setMapper 

  パラメーター:

  mapper - 設定するマッパー。デフォルトは TcpMessageMapper です

• isSingleUse

  public boolean isSingleUse()

  オーバーライド:

  クラス AbstractConnectionFactory の isSingleUse 

  戻り値:

  singleUse

• setSingleUse

  public void setSingleUse(boolean singleUse)

  このファクトリでは無視されます。接続は常にプールにキャッシュされます。基礎となる接続ファクトリの singleUse プロパティは強制的に true に設定されます (これにより接続が返されます)。初期化後に基礎となるファクトリでこれを false に設定すると、キャッシュ不足が発生します。

  オーバーライド:

  クラス AbstractConnectionFactory の setSingleUse 

  パラメーター:

  singleUse - singleUse。

• setInterceptorFactoryChain

  public void setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)

  オーバーライド:

  クラス AbstractConnectionFactory の setInterceptorFactoryChain 

• setLookupHost

  public void setLookupHost(boolean lookupHost)

  クラスからコピーされた説明: AbstractConnectionFactory

  true の場合、リモート IP アドレスで DNS 逆引き参照が行われます。デフォルト false: すべての環境 (例: Docker コンテナー) が信頼できる DNS 解決を実行するわけではありません。

  オーバーライド:

  クラス AbstractConnectionFactory の setLookupHost 

  パラメーター:

  lookupHost - 設定する lookupHost

• isLookupHost

  public boolean isLookupHost()

  オーバーライド:

  クラス AbstractConnectionFactory の isLookupHost 

  戻り値:

  lookupHost

• forceClose

  public void forceClose(TcpConnection connection)

  クラスからコピーされた説明: AbstractClientConnectionFactory

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

  オーバーライド:

  クラス AbstractClientConnectionFactory の forceClose 

  パラメーター:

  connection - 接続。

• enableManualListenerRegistration

  public void enableManualListenerRegistration()

  クラスからコピーされた説明: AbstractClientConnectionFactory

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

  オーバーライド:

  クラス AbstractClientConnectionFactory の enableManualListenerRegistration 

• closeConnection

  public boolean closeConnection(StringSE connectionId)

  クラスからコピーされた説明: AbstractConnectionFactory

  指定された接続 ID の接続を閉じます。

  オーバーライド:

  クラス AbstractConnectionFactory の closeConnection 

  パラメーター:

  connectionId - 接続 ID。

  戻り値:

  接続が閉じられた場合は true。

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

  次で指定:

  インターフェース ManageableLifecycle の start 

  オーバーライド:

  クラス AbstractConnectionFactory の start 

• stop

  public void stop()

  クラスからコピーされた説明: AbstractConnectionFactory

  サーバーの停止。

  次で指定:

  インターフェース Lifecycle の stop 

  次で指定:

  インターフェース ManageableLifecycle の stop 

  オーバーライド:

  クラス AbstractConnectionFactory の stop 

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy