public class TcpReceivingChannelAdapter extends MessageProducerSupport implements TcpListener, ClientModeCapable, OrderlyShutdownCapable
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
DEFAULT_PHASE
コンストラクターと説明 |
---|
TcpReceivingChannelAdapter() |
修飾子と型 | メソッドと説明 |
---|---|
int | afterShutdown() スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。 |
int | beforeShutdown() シャットダウンが始まる前に呼び出されます。 |
protected void | doStart() デフォルトでは何もしません。 |
protected void | doStop() デフォルトでは何もしません。 |
protected ConnectionFactory | getClientConnectionFactory() |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
long | getRetryInterval() |
protected ConnectionFactory | getServerConnectionFactory() |
boolean | isClientMode() |
boolean | isClientModeConnected() |
boolean | isListening() |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
boolean | onMessage(Message<?> message) 新しいメッセージが到着したときに TCPConnection によって呼び出されます。 |
void | retryConnection() すぐに接続の確立を試みてください。 |
void | setClientMode(boolean isClientMode) |
void | setConnectionFactory(AbstractConnectionFactory connectionFactory) クライアントまたはサーバー接続ファクトリを設定します。この場合(受信アダプター)、ファクトリがクライアント接続ファクトリである場合、ソケットは送信チャネルアダプターによって所有され、このアダプターは応答の受信に使用されます。 |
void | setRetryInterval(long retryInterval) |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getBeanName, getComponentName
public boolean onMessage(Message<?> message)
TcpListener
TcpListener
の onMessage
message
- メッセージ。protected void onInit()
IntegrationObjectSupport
MessageProducerSupport
の onInit
protected void doStart()
MessageProducerSupport
MessageProducerSupport
の doStart
protected void doStop()
MessageProducerSupport
MessageProducerSupport
の doStop
public void setConnectionFactory(AbstractConnectionFactory connectionFactory)
connectionFactory
- 設定する connectionFactorypublic boolean isListening()
public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
IntegrationObjectSupport
の getComponentType
protected ConnectionFactory getClientConnectionFactory()
protected ConnectionFactory getServerConnectionFactory()
public boolean isClientMode()
ClientModeCapable
の isClientMode
public void setClientMode(boolean isClientMode)
isClientMode
- 設定する isClientModepublic long getRetryInterval()
public void setRetryInterval(long retryInterval)
retryInterval
- 設定する retryIntervalpublic boolean isClientModeConnected()
ClientModeCapable
の isClientModeConnected
public void retryConnection()
ClientModeCapable
ClientModeCapable
の retryConnection
public int beforeShutdown()
OrderlyShutdownCapable
OrderlyShutdownCapable
の beforeShutdown
public int afterShutdown()
OrderlyShutdownCapable
OrderlyShutdownCapable
の afterShutdown