public class ThreadAffinityClientConnectionFactory extends AbstractClientConnectionFactory
releaseConnection()
を呼び出します。DEFAULT_REPLY_TIMEOUT, lifecycleMonitor
EXPRESSION_PARSER, logger
コンストラクターと説明 |
---|
ThreadAffinityClientConnectionFactory(AbstractClientConnectionFactory connectionFactory) |
修飾子と型 | メソッドと説明 |
---|---|
boolean | closeConnection(StringSE connectionId) 指定された接続 ID の接続を閉じます。 |
void | enableManualListenerRegistration() このファクトリによって作成された接続に自動的に(デフォルト)または TcpListener を追加するかどうかを設定します。 |
void | forceClose(TcpConnection connection) 接続を強制的に閉じ、共有接続の場合はフィールドを null にします。 |
StringSE | getApplicationContextId() ApplicationContext が使用可能な場合、ApplicationContext.getId() を返します。 |
ApplicationEventPublisher | getApplicationEventPublisher() |
StringSE | getComponentName() IntegrationObjectSupport.componentName フィールドで識別されるこのコンポーネントの名前を返します。 |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
TcpConnectionSupport | getConnection() 接続を取得します。 AbstractConnectionFactory.setSingleUse(boolean) が true で呼び出された場合、新しい接続が返されます。そうでない場合は、接続が開いたままである間、すべてのリクエストに対して単一の接続が再利用されます。 |
ConversionService | getConversionService() |
Deserializer<?> | getDeserializer() |
Expression | getExpression() このコンポーネントが式ベースの場合、プライマリ SpEL 式を返します。 |
StringSE | getHost() |
TcpListener | getListener() |
TcpMessageMapper | getMapper() |
ListSE<StringSE> | getOpenConnectionIds() (現在)開いている TcpConnection 接続 ID のリストを返します。たとえば、開いているすべての接続へのブロードキャスト操作を許可します。 |
int | getPort() |
TcpSender | getSender() |
ListSE<TcpSender> | getSenders() 送信者のリストを返します。 |
Serializer<?> | getSerializer() |
int | getSoLinger() |
int | getSoReceiveBufferSize() |
int | getSoSendBufferSize() |
int | getSoTimeout() |
int | getSoTrafficClass() |
boolean | isLookupHost() |
boolean | isRunning() |
boolean | isSoKeepAlive() |
boolean | isSoTcpNoDelay() |
void | registerListener(TcpListener listener) ペイロードが入力データから変換された後、メッセージを受信するために TcpListener を登録します。 |
void | registerSender(TcpSender sender) TcpSender を登録します。サーバーソケットの場合、接続情報を提供するために使用されるため、送信者は受信メッセージに返信するために使用できます。 |
void | releaseConnection() |
void | setApplicationContext(ApplicationContext applicationContext) |
void | setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void | setBeanFactory(BeanFactory beanFactory) |
void | setChannelResolver(DestinationResolver<MessageChannel> channelResolver) 使用する DestinationResolver 戦略を指定します。 |
void | setComponentName(StringSE componentName) このコンポーネントの名前を設定します。 |
void | setDeserializer(Deserializer<?> deserializer) |
void | setHost(StringSE host) ホストを設定します。ファクトリを停止する必要があります。 |
void | setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain) |
void | setLookupHost(boolean lookupHost) true の場合、リモート IP アドレスで DNS 逆ルックアップが行われます。 |
void | setMapper(TcpMessageMapper mapper) |
void | setMessageBuilderFactory(MessageBuilderFactory messageBuilderFactory) |
void | setNioHarvestInterval(int nioHarvestInterval) soTimeout が 0 の場合に閉じられた NIO 接続をクリーンアップする頻度。 |
void | setPort(int port) ポートを設定します。ファクトリを停止する必要があります。 |
void | setReadDelay(long readDelay) 前の試行がスレッド不足のために失敗した後、読み取りを再試行するまでの遅延(ミリ秒)。 |
void | setSerializer(Serializer<?> serializer) |
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 | setSslHandshakeTimeout(int sslHandshakeTimeout) SSL ハンドシェイクデータを待機するときに使用されるハンドシェイクタイムアウトを設定します。NIO を使用する場合、SSL 接続にのみ適用されます。 |
void | setTaskExecutor(ExecutorSE taskExecutor) |
void | setTcpSocketSupport(TcpSocketSupport tcpSocketSupport) |
void | start() |
void | stop() サーバーの停止。 |
StringSE | toString() |
buildNewConnection, getConnectionTest, getConnectTimeout, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setConnectionTest, setConnectTimeout, setTheConnection
addConnection, checkActive, delayRead, doAccept, getDelayedReads, getLifecycleMonitor, getReadDelay, getSslHandshakeTimeout, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, isSingleUse, onInit, processNioSelections, setActive, setLeaveOpen, setSingleUse, setSocketAttributes, unregisterSender, wrapConnection
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setBeanName, setConversionService, setPrimaryExpression, setTaskScheduler
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
public ThreadAffinityClientConnectionFactory(AbstractClientConnectionFactory connectionFactory)
public TcpConnectionSupport getConnection() throws InterruptedExceptionSE
AbstractClientConnectionFactory
AbstractConnectionFactory.setSingleUse(boolean)
が true で呼び出された場合、新しい接続が返されます。そうでない場合は、接続が開いたままである間、すべてのリクエストに対して単一の接続が再利用されます。ConnectionFactory
の getConnection
AbstractClientConnectionFactory
の getConnection
InterruptedExceptionSE
- 中断された場合。public void releaseConnection()
public void enableManualListenerRegistration()
AbstractClientConnectionFactory
TcpListener
を追加するかどうかを設定します。デフォルトでは、ファクトリはリスナーを自動的に構成します。手動登録が行われると、リスナーが登録されるまで受信メッセージが遅延します。AbstractClientConnectionFactory
の enableManualListenerRegistration
public StringSE getComponentName()
IntegrationObjectSupport
IntegrationObjectSupport.componentName
フィールドで識別されるこのコンポーネントの名前を返します。IntegrationObjectSupport.componentName
が設定されていない場合、このメソッドはデフォルトでこのコンポーネントの 'beanName' になります。NamedComponent
の getComponentName
IntegrationObjectSupport
の getComponentName
public void setComponentName(StringSE componentName)
IntegrationObjectSupport
IntegrationObjectSupport
の setComponentName
componentName
- コンポーネント名。public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
ApplicationEventPublisherAware
の setApplicationEventPublisher
AbstractConnectionFactory
の setApplicationEventPublisher
public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
IntegrationObjectSupport
の getComponentType
public void setBeanFactory(BeanFactory beanFactory)
BeanFactoryAware
の setBeanFactory
IntegrationObjectSupport
の setBeanFactory
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
ApplicationContextAware
の setApplicationContext
IntegrationObjectSupport
の setApplicationContext
BeansException
@Nullable public ApplicationEventPublisher getApplicationEventPublisher()
AbstractConnectionFactory
の getApplicationEventPublisher
public void setChannelResolver(DestinationResolver<MessageChannel> channelResolver)
IntegrationObjectSupport
DestinationResolver
戦略を指定します。デフォルトは BeanFactoryChannelResolver です。IntegrationObjectSupport
の setChannelResolver
channelResolver
- チャネルリゾルバー。public Expression getExpression()
ExpressionCapable
ExpressionCapable
の getExpression
IntegrationObjectSupport
の getExpression
public void forceClose(TcpConnection connection)
AbstractClientConnectionFactory
AbstractClientConnectionFactory
の forceClose
connection
- 接続。public int getSoTimeout()
AbstractConnectionFactory
の getSoTimeout
public void setSoTimeout(int soTimeout)
AbstractConnectionFactory
の setSoTimeout
soTimeout
- 設定する soTimeoutpublic int getSoReceiveBufferSize()
AbstractConnectionFactory
の getSoReceiveBufferSize
public void setSoReceiveBufferSize(int soReceiveBufferSize)
AbstractConnectionFactory
の setSoReceiveBufferSize
soReceiveBufferSize
- 設定する soReceiveBufferSizepublic int getSoSendBufferSize()
AbstractConnectionFactory
の getSoSendBufferSize
public void setSoSendBufferSize(int soSendBufferSize)
AbstractConnectionFactory
の setSoSendBufferSize
soSendBufferSize
- 設定する soSendBufferSizepublic boolean isSoTcpNoDelay()
AbstractConnectionFactory
の isSoTcpNoDelay
public void setSoTcpNoDelay(boolean soTcpNoDelay)
AbstractConnectionFactory
の setSoTcpNoDelay
soTcpNoDelay
- 設定する soTcpNoDelaypublic int getSoLinger()
AbstractConnectionFactory
の getSoLinger
public void setSoLinger(int soLinger)
AbstractConnectionFactory
の setSoLinger
soLinger
- 設定する soLingerpublic boolean isSoKeepAlive()
AbstractConnectionFactory
の isSoKeepAlive
public void setSoKeepAlive(boolean soKeepAlive)
AbstractConnectionFactory
の setSoKeepAlive
soKeepAlive
- 設定する soKeepAlivepublic ConversionService getConversionService()
IntegrationObjectSupport
の getConversionService
public int getSoTrafficClass()
AbstractConnectionFactory
の getSoTrafficClass
public void setSoTrafficClass(int soTrafficClass)
AbstractConnectionFactory
の setSoTrafficClass
soTrafficClass
- 設定する soTrafficClasspublic void setHost(StringSE host)
AbstractConnectionFactory
AbstractConnectionFactory
の setHost
host
- ザホスト。public StringSE getHost()
AbstractConnectionFactory
の getHost
public void setPort(int port)
AbstractConnectionFactory
AbstractConnectionFactory
の setPort
port
- ポート。public StringSE getApplicationContextId()
IntegrationObjectSupport
ApplicationContext
が使用可能な場合、ApplicationContext.getId()
を返します。IntegrationObjectSupport
の getApplicationContextId
public int getPort()
AbstractConnectionFactory
の getPort
public TcpListener getListener()
AbstractConnectionFactory
の getListener
public TcpSender getSender()
AbstractConnectionFactory
の getSender
public ListSE<TcpSender> getSenders()
AbstractConnectionFactory
AbstractConnectionFactory
の getSenders
public Serializer<?> getSerializer()
AbstractConnectionFactory
の getSerializer
public Deserializer<?> getDeserializer()
AbstractConnectionFactory
の getDeserializer
public TcpMessageMapper getMapper()
AbstractConnectionFactory
の getMapper
public void registerListener(TcpListener listener)
AbstractConnectionFactory
AbstractConnectionFactory
の registerListener
listener
- TcpListener。public void setMessageBuilderFactory(MessageBuilderFactory messageBuilderFactory)
IntegrationObjectSupport
の setMessageBuilderFactory
public void registerSender(TcpSender sender)
AbstractConnectionFactory
AbstractConnectionFactory
の registerSender
sender
- 送り主 public void setTaskExecutor(ExecutorSE taskExecutor)
AbstractConnectionFactory
の setTaskExecutor
taskExecutor
- 設定する taskExecutorpublic void setDeserializer(Deserializer<?> deserializer)
AbstractConnectionFactory
の setDeserializer
deserializer
- 設定するデシリアライザー public void setSerializer(Serializer<?> serializer)
AbstractConnectionFactory
の setSerializer
serializer
- 設定するシリアライザー public void setMapper(TcpMessageMapper mapper)
AbstractConnectionFactory
の setMapper
mapper
- 設定するマッパー。デフォルトは TcpMessageMapper
です public void setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)
AbstractConnectionFactory
の setInterceptorFactoryChain
public void setLookupHost(boolean lookupHost)
AbstractConnectionFactory
AbstractConnectionFactory
の setLookupHost
lookupHost
- 設定する lookupHostpublic boolean isLookupHost()
AbstractConnectionFactory
の isLookupHost
public void setNioHarvestInterval(int nioHarvestInterval)
AbstractConnectionFactory
soTimeout > 0
の場合は無視されます。デフォルトは 2000 ミリ秒です。AbstractConnectionFactory
の setNioHarvestInterval
nioHarvestInterval
- ミリ秒単位の間隔。public void setSslHandshakeTimeout(int sslHandshakeTimeout)
AbstractConnectionFactory
AbstractConnectionFactory
の setSslHandshakeTimeout
sslHandshakeTimeout
- タイムアウト。public void setReadDelay(long readDelay)
AbstractConnectionFactory
AbstractConnectionFactory
の setReadDelay
readDelay
- readDelay を設定します。public void start()
Lifecycle
の start
ManageableLifecycle
の start
AbstractConnectionFactory
の start
public void stop()
AbstractConnectionFactory
Lifecycle
の stop
ManageableLifecycle
の stop
AbstractConnectionFactory
の stop
public boolean isRunning()
Lifecycle
の isRunning
ManageableLifecycle
の isRunning
AbstractConnectionFactory
の isRunning
public void setTcpSocketSupport(TcpSocketSupport tcpSocketSupport)
AbstractConnectionFactory
の setTcpSocketSupport
public ListSE<StringSE> getOpenConnectionIds()
AbstractConnectionFactory
TcpConnection
接続 ID のリストを返します。たとえば、開いているすべての接続へのブロードキャスト操作を許可します。AbstractConnectionFactory
の getOpenConnectionIds
public boolean closeConnection(StringSE connectionId)
AbstractConnectionFactory
AbstractConnectionFactory
の closeConnection
connectionId
- 接続 ID。public StringSE toString()
AbstractConnectionFactory
の toString