クラス ThreadAffinityClientConnectionFactory

メソッドの詳細

• getConnection

  public TcpConnectionSupport getConnection() throws InterruptedExceptionSE

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

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

  次で指定:

  インターフェース ConnectionFactory の getConnection 

  オーバーライド:

  クラス AbstractClientConnectionFactory の getConnection 

  例外:

  InterruptedExceptionSE - 中断された場合。

• releaseConnection

  public void releaseConnection()

• enableManualListenerRegistration

  public void enableManualListenerRegistration()

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

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

  オーバーライド:

  クラス AbstractClientConnectionFactory の enableManualListenerRegistration 

• getComponentName

  public StringSE getComponentName()

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

  IntegrationObjectSupport.componentName フィールドで識別されるこのコンポーネントの名前を返します。IntegrationObjectSupport.componentName が設定されていない場合、このメソッドはデフォルトでこのコンポーネントの 'beanName' になります。

  次で指定:

  インターフェース NamedComponent の getComponentName 

  オーバーライド:

  クラス IntegrationObjectSupport の getComponentName 

• setComponentName

  public void setComponentName(StringSE componentName)

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

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

  オーバーライド:

  クラス IntegrationObjectSupport の setComponentName 

  パラメーター:

  componentName - コンポーネント名。

• setApplicationEventPublisher

  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

  次で指定:

  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

  オーバーライド:

  クラス AbstractConnectionFactory の setApplicationEventPublisher 

• getComponentType

  public StringSE getComponentType()

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

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

  次で指定:

  インターフェース NamedComponent の getComponentType 

  オーバーライド:

  クラス IntegrationObjectSupport の getComponentType 

• setBeanFactory

  public void setBeanFactory(BeanFactory beanFactory)

  次で指定:

  インターフェース BeanFactoryAware の setBeanFactory 

  オーバーライド:

  クラス IntegrationObjectSupport の setBeanFactory 

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  オーバーライド:

  クラス IntegrationObjectSupport の setApplicationContext 

  例外:

  BeansException

• getApplicationEventPublisher

  @Nullable public ApplicationEventPublisher getApplicationEventPublisher()

  オーバーライド:

  クラス AbstractConnectionFactory の getApplicationEventPublisher 

• setChannelResolver

  public void setChannelResolver(DestinationResolver<MessageChannel> channelResolver)

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

  使用する DestinationResolver 戦略を指定します。デフォルトは BeanFactoryChannelResolver です。

  オーバーライド:

  クラス IntegrationObjectSupport の setChannelResolver 

  パラメーター:

  channelResolver - チャネルリゾルバー。

• getExpression

  public Expression getExpression()

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

  このコンポーネントが式ベースの場合、プライマリ SpEL 式を返します。

  次で指定:

  インターフェース ExpressionCapable の getExpression 

  オーバーライド:

  クラス IntegrationObjectSupport の getExpression 

  戻り値:

  文字列としての式。

• forceClose

  public void forceClose(TcpConnection connection)

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

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

  オーバーライド:

  クラス AbstractClientConnectionFactory の forceClose 

  パラメーター:

  connection - 接続。

• 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

• getConversionService

  public ConversionService getConversionService()

  オーバーライド:

  クラス IntegrationObjectSupport の getConversionService 

• getSoTrafficClass

  public int getSoTrafficClass()

  オーバーライド:

  クラス AbstractConnectionFactory の getSoTrafficClass 

  戻り値:

  soTrafficClass

• setSoTrafficClass

  public void setSoTrafficClass(int soTrafficClass)

  オーバーライド:

  クラス AbstractConnectionFactory の setSoTrafficClass 

  パラメーター:

  soTrafficClass - 設定する soTrafficClass

• setHost

  public void setHost(StringSE host)

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

  ホストを設定します。ファクトリを停止する必要があります。

  オーバーライド:

  クラス AbstractConnectionFactory の setHost 

  パラメーター:

  host - ザホスト。

• getHost

  public StringSE getHost()

  オーバーライド:

  クラス AbstractConnectionFactory の getHost 

  戻り値:

  ザホスト

• setPort

  public void setPort(int port)

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

  ポートを設定します。ファクトリを停止する必要があります。

  オーバーライド:

  クラス AbstractConnectionFactory の setPort 

  パラメーター:

  port - ポート。

• getApplicationContextId

  public StringSE getApplicationContextId()

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

  ApplicationContext が使用可能な場合、ApplicationContext.getId() を返します。

  オーバーライド:

  クラス IntegrationObjectSupport の getApplicationContextId 

  戻り値:

  id、またはアプリケーションコンテキストがない場合は null。

• getPort

  public int getPort()

  オーバーライド:

  クラス AbstractConnectionFactory の getPort 

  戻り値:

  港

• getListener

  public TcpListener getListener()

  オーバーライド:

  クラス AbstractConnectionFactory の getListener 

  戻り値:

  リスナー

• getSender

  public TcpSender getSender()

  オーバーライド:

  クラス AbstractConnectionFactory の getSender 

  戻り値:

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

• getSenders

  public ListSE<TcpSender> getSenders()

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

  送信者のリストを返します。

  オーバーライド:

  クラス AbstractConnectionFactory の getSenders 

  戻り値:

  送信者。

• getSerializer

  public Serializer<?> getSerializer()

  オーバーライド:

  クラス AbstractConnectionFactory の getSerializer 

  戻り値:

  シリアライザー

• getDeserializer

  public Deserializer<?> getDeserializer()

  オーバーライド:

  クラス AbstractConnectionFactory の getDeserializer 

  戻り値:

  デシリアライザー

• getMapper

  public TcpMessageMapper getMapper()

  オーバーライド:

  クラス AbstractConnectionFactory の getMapper 

  戻り値:

  マッパー

• registerListener

  public void registerListener(TcpListener listener)

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

  ペイロードが入力データから変換された後、メッセージを受信するために TcpListener を登録します。

  オーバーライド:

  クラス AbstractConnectionFactory の registerListener 

  パラメーター:

  listener - TcpListener。

• setMessageBuilderFactory

  public void setMessageBuilderFactory(MessageBuilderFactory messageBuilderFactory)

  オーバーライド:

  クラス IntegrationObjectSupport の setMessageBuilderFactory 

• 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 です

• 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

• setNioHarvestInterval

  public void setNioHarvestInterval(int nioHarvestInterval)

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

  soTimeout が 0 の場合、閉じられた NIO 接続をクリーンアップする頻度。クリーンアッププロセスはタイムアウト処理の一部として実行されるため、soTimeout > 0 の場合は無視されます。デフォルトは 2000 ミリ秒です。

  オーバーライド:

  クラス AbstractConnectionFactory の setNioHarvestInterval 

  パラメーター:

  nioHarvestInterval - ミリ秒単位の間隔。

• setSslHandshakeTimeout

  public void setSslHandshakeTimeout(int sslHandshakeTimeout)

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

  SSL ハンドシェイクデータを待機するときに使用されるハンドシェイクタイムアウトを設定します。NIO を使用する場合、SSL 接続にのみ適用されます。

  オーバーライド:

  クラス AbstractConnectionFactory の setSslHandshakeTimeout 

  パラメーター:

  sslHandshakeTimeout - タイムアウト。

• setReadDelay

  public void setReadDelay(long readDelay)

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

  スレッドが不十分なために前回の試行が失敗した後、読み取りを再試行するまでの遅延（ミリ秒単位）。デフォルトは 100。

  オーバーライド:

  クラス AbstractConnectionFactory の setReadDelay 

  パラメーター:

  readDelay - readDelay を設定します。

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

  次で指定:

  インターフェース ManageableLifecycle の start 

  オーバーライド:

  クラス AbstractConnectionFactory の start 

• stop

  public void stop()

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

  サーバーの停止。

  次で指定:

  インターフェース Lifecycle の stop 

  次で指定:

  インターフェース ManageableLifecycle の stop 

  オーバーライド:

  クラス AbstractConnectionFactory の stop 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

  次で指定:

  インターフェース ManageableLifecycle の isRunning 

  オーバーライド:

  クラス AbstractConnectionFactory の isRunning 

• setTcpSocketSupport

  public void setTcpSocketSupport(TcpSocketSupport tcpSocketSupport)

  オーバーライド:

  クラス AbstractConnectionFactory の setTcpSocketSupport 

• getOpenConnectionIds

  public ListSE<StringSE> getOpenConnectionIds()

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

  （現在）開いている TcpConnection 接続 ID のリストを返します。たとえば、開いているすべての接続へのブロードキャスト操作を許可します。

  オーバーライド:

  クラス AbstractConnectionFactory の getOpenConnectionIds 

  戻り値:

  接続 ID のリスト。

• closeConnection

  public boolean closeConnection(StringSE connectionId)

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

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

  オーバーライド:

  クラス AbstractConnectionFactory の closeConnection 

  パラメーター:

  connectionId - 接続 ID。

  戻り値:

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

• toString

  public StringSE toString()

  オーバーライド:

  クラス AbstractConnectionFactory の toString