CachingClientConnectionFactory (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
  - - org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory
    - - org.springframework.integration.ip.tcp.connection.CachingClientConnectionFactory

実装されているすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, ExpressionCapable, ConnectionFactory, NamedComponent, ManageableLifecycle
```
public class CachingClientConnectionFactory
extends AbstractClientConnectionFactory
implements DisposableBean
```
基礎となるターゲットファクトリからの接続をキャッシュする接続ファクトリ。使用後に接続がキャッシュに戻されるように、基になるファクトリは singleUse=true を持つように再構成されます。ユーザーはその後、基になるプロパティを false に設定しないでください。設定すると、キャッシュが不足します。
導入:
2.2
作成者:
Gary Russell

フィールドのサマリー
- クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたフィールド
  DEFAULT_REPLY_TIMEOUT, lifecycleMonitor
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger

コンストラクターの概要

コンストラクター
コンストラクターと説明
`CachingClientConnectionFactory(AbstractClientConnectionFactory target, int poolSize)` 指定されたプールサイズで、指定されたファクトリに委譲するキャッシュ接続ファクトリを構築します。

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`void`	`destroy()`
`void`	`enableManualListenerRegistration()` このファクトリによって作成された接続に自動的に（デフォルト）または `TcpListener` を追加するかどうかを設定します。
`boolean`	`equals(ObjectSE o)`
`void`	`forceClose(TcpConnection connection)` 接続を強制的に閉じ、共有接続の場合はフィールドを null にします。
`int`	`getActiveCount()`
`int`	`getAllocatedCount()`
`StringSE`	`getComponentType()` サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
`Deserializer<?>`	`getDeserializer()`
`StringSE`	`getHost()`
`int`	`getIdleCount()`
`TcpMessageMapper`	`getMapper()`
`int`	`getPoolSize()`
`int`	`getPort()`
`TcpSender`	`getSender()`
`Serializer<?>`	`getSerializer()`
`int`	`getSoLinger()`
`int`	`getSoReceiveBufferSize()`
`int`	`getSoSendBufferSize()`
`int`	`getSoTimeout()`
`int`	`getSoTrafficClass()`
`int`	`hashCode()`
`boolean`	`isLookupHost()`
`boolean`	`isRunning()`
`boolean`	`isSingleUse()`
`boolean`	`isSoKeepAlive()`
`boolean`	`isSoTcpNoDelay()`
`TcpConnectionSupport`	`obtainConnection()`
`void`	`registerListener(TcpListener listener)` データの受信に使用されるデリゲート TCP クライアント接続ファクトリには、メッセージを送信するリスナーが必要です。
`void`	`registerSender(TcpSender sender)` TcpSender を登録します。サーバーソケットの場合、接続情報を提供するために使用されるため、送信者は受信メッセージに返信するために使用できます。
`void`	`setComponentName(StringSE componentName)` このコンポーネントの名前を設定します。
`void`	`setConnectionWaitTimeout(int connectionWaitTimeout)`
`void`	`setDeserializer(Deserializer<?> deserializer)`
`void`	`setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)`
`void`	`setLookupHost(boolean lookupHost)` true の場合、リモート IP アドレスで DNS 逆ルックアップが行われます。
`void`	`setMapper(TcpMessageMapper mapper)`
`void`	`setPoolSize(int poolSize)`
`void`	`setSerializer(Serializer<?> serializer)`
`void`	`setSingleUse(boolean singleUse)` このファクトリでは無視されます。接続は常にプールにキャッシュされます。
`void`	`setSoKeepAlive(boolean soKeepAlive)`
`void`	`setSoLinger(int soLinger)`
`void`	`setSoReceiveBufferSize(int soReceiveBufferSize)`
`void`	`setSoSendBufferSize(int soSendBufferSize)`
`void`	`setSoTcpNoDelay(boolean soTcpNoDelay)`
`void`	`setSoTimeout(int soTimeout)`
`void`	`setSoTrafficClass(int soTrafficClass)`
`void`	`setTaskExecutor(ExecutorSE taskExecutor)`
`void`	`start()`
`void`	`stop()` サーバーの停止。

クラス org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory から継承されたメソッド
buildNewConnection, getConnection, getConnectionTest, getConnectTimeout, getTheConnection, initializeConnection, obtainNewConnection, obtainSharedConnection, setConnectionTest, setConnectTimeout, setTheConnection

クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたメソッド
addConnection, checkActive, closeConnection, delayRead, doAccept, getApplicationEventPublisher, getDelayedReads, getLifecycleMonitor, getListener, getOpenConnectionIds, getReadDelay, getSenders, getSslHandshakeTimeout, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, onInit, processNioSelections, setActive, setApplicationEventPublisher, setHost, setLeaveOpen, setNioHarvestInterval, setPort, setReadDelay, setSocketAttributes, setSslHandshakeTimeout, setTcpSocketSupport, toString, unregisterSender, wrapConnection

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, finalizeSE, getClassSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

- コンストラクターの詳細
  - CachingClientConnectionFactory
```
public CachingClientConnectionFactory(AbstractClientConnectionFactory target,
                                      int poolSize)
```
    指定されたプールサイズで、指定されたファクトリに委譲するキャッシュ接続ファクトリを構築します。
    パラメーター:
    target - ターゲットファクトリ。
    poolSize - 許可する接続の数。
- メソッドの詳細
  - 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 の hashCodeSE
  - 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 の場合、DNS 逆ルックアップはリモート IP アドレスで行われます。デフォルトは true です。
    オーバーライド:
    クラス 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
  - 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()
             throws ExceptionSE
```
    次で指定:
    インターフェース DisposableBean の destroy
    例外:
    ExceptionSE

クラス CachingClientConnectionFactory

フィールドのサマリー

クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory から継承されたメソッド

クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

コンストラクターの詳細

CachingClientConnectionFactory

メソッドの詳細

setConnectionWaitTimeout

setPoolSize

getPoolSize

getIdleCount

getActiveCount

getAllocatedCount

obtainConnection

isRunning

hashCode

setComponentName

getComponentType

equals

getSoTimeout

setSoTimeout

getSoReceiveBufferSize

setSoReceiveBufferSize

getSoSendBufferSize

setSoSendBufferSize

isSoTcpNoDelay

setSoTcpNoDelay

getSoLinger

setSoLinger

isSoKeepAlive

setSoKeepAlive

getSoTrafficClass

setSoTrafficClass

getHost

getPort

getSender

getSerializer

getDeserializer

getMapper

registerListener

registerSender

setTaskExecutor

setDeserializer

setSerializer

setMapper

isSingleUse

setSingleUse

setInterceptorFactoryChain

setLookupHost

isLookupHost

forceClose

enableManualListenerRegistration

start

stop

destroy