クラス TcpInboundGateway
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.gateway.MessagingGatewaySupport
org.springframework.integration.ip.tcp.TcpInboundGateway
- 実装されたすべてのインターフェース:
Aware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、InitializingBean
、ApplicationContextAware
、Lifecycle
、Phased
、SmartLifecycle
、ComponentSourceAware
、ExpressionCapable
、OrderlyShutdownCapable
、IntegrationPattern
、ClientModeCapable
、TcpListener
、TcpSender
、NamedComponent
、IntegrationInboundManagement
、IntegrationManagement
、ManageableLifecycle
、ManageableSmartLifecycle
、TrackableComponent
public class TcpInboundGateway
extends MessagingGatewaySupport
implements TcpListener, TcpSender, ClientModeCapable, OrderlyShutdownCapable
サーバー接続ファクトリを使用する受信ゲートウェイ - スレッドはファクトリによって制御されます。java.net 接続の場合、各ソケットは一度に 1 つのメッセージしか処理できません。java.nio 接続の場合、メッセージは多重化される可能性がありますが、クライアントは相関ロジックを提供する必要があります。クライアントが
TcpOutboundGateway
の場合、多重化は使用されませんが、接続ファクトリがシングルユース接続を使用する場合は、複数の同時接続を使用できます。真の非同期双方向通信には、受信 / 送信チャネルアダプターのペアを使用する必要があります。- 導入:
- 2.0
- 作成者:
- Gary Russell, Artem Bilan
ネストされたクラスのサマリー
クラス org.springframework.integration.gateway.MessagingGatewaySupport から継承されたネストクラス / インターフェース
MessagingGatewaySupport.ConvertingMessagingTemplate
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドのサマリー
フィールドクラス org.springframework.integration.gateway.MessagingGatewaySupport から継承されたフィールド
messagingTemplate
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
lifecycleLock
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明void
addNewConnection
(TcpConnection connection) TcpListener
が所有するソケットを使用している場合、このメソッドは新しい接続が確立されるたびに呼び出されます。int
スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。int
シャットダウンが始まる前に呼び出されます。protected void
doStart()
サブクラスは、開始動作でこのメソッドを実装する必要があります。protected void
doStop()
サブクラスは、停止動作でこのメソッドを実装する必要があります。サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。long
boolean
boolean
boolean
protected void
onInit()
サブクラスは、初期化ロジック用にこれを実装できます。boolean
新しいメッセージが到着したときに TCPConnection によって呼び出されます。void
removeDeadConnection
(TcpConnection connection) TcpListener
が所有するソケットを使用している場合、このメソッドは接続が閉じられるたびに呼び出されます。void
すぐに接続の確立を試みてください。void
setClientMode
(boolean isClientMode) void
setConnectionFactory
(AbstractConnectionFactory connectionFactory) AbstractClientConnectionFactory
またはAbstractServerConnectionFactory
である必要があります。void
setRetryInterval
(long retryInterval) 再試行間隔を構成します。クラス org.springframework.integration.gateway.MessagingGatewaySupport から継承されたメソッド
buildErrorMessage, buildSendTimer, destroy, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getManagedName, getManagedType, getOverrides, getReplyChannel, getRequestChannel, isLoggingEnabled, isObserved, receive, receive, receiveMessage, receiveMessage, registerMetricsCaptor, registerObservationRegistry, registerReplyMessageCorrelatorIfNecessary, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, sendTimer, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setErrorOnTimeout, setLoggingEnabled, setManagedName, setManagedType, setObservationConvention, setReceiverObservationConvention, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrack
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
フィールドの詳細
DEFAULT_RETRY_INTERVAL
public static final long DEFAULT_RETRY_INTERVALミリ秒単位のデフォルトの再試行間隔 -60000L。- 関連事項:
コンストラクターの詳細
TcpInboundGateway
public TcpInboundGateway()
メソッドの詳細
onMessage
インターフェースからコピーされた説明:TcpListener
新しいメッセージが到着したときに TCPConnection によって呼び出されます。- 次で指定:
- インターフェース
TcpListener
のonMessage
- パラメーター:
message
- メッセージ。- 戻り値:
- メッセージがインターセプトされた場合は true
isListening
public boolean isListening()- 戻り値:
- 関連する接続ファクトリがリッスンしている場合は true。
setConnectionFactory
AbstractClientConnectionFactory
またはAbstractServerConnectionFactory
である必要があります。- パラメーター:
connectionFactory
- 接続ファクトリ
addNewConnection
インターフェースからコピーされた説明:TcpSender
TcpListener
が所有するソケットを使用している場合、このメソッドは新しい接続が確立されるたびに呼び出されます。- 次で指定:
- インターフェース
TcpSender
のaddNewConnection
- パラメーター:
connection
- 接続。
removeDeadConnection
インターフェースからコピーされた説明:TcpSender
TcpListener
が所有するソケットを使用している場合、このメソッドは接続が閉じられるたびに呼び出されます。- 次で指定:
- インターフェース
TcpSender
のremoveDeadConnection
- パラメーター:
connection
- 接続。
getComponentType
クラスからコピーされた説明:IntegrationObjectSupport
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。- 次で指定:
- インターフェース
NamedComponent
のgetComponentType
- オーバーライド:
- クラス
MessagingGatewaySupport
のgetComponentType
onInit
protected void onInit()クラスからコピーされた説明:IntegrationObjectSupport
サブクラスは、初期化ロジック用にこれを実装できます。- オーバーライド:
- クラス
MessagingGatewaySupport
のonInit
doStart
protected void doStart()クラスからコピーされた説明:AbstractEndpoint
サブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock
を保持しているときに呼び出されます。- オーバーライド:
- クラス
MessagingGatewaySupport
のdoStart
doStop
protected void doStop()クラスからコピーされた説明:AbstractEndpoint
サブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock
を保持しているときに呼び出されます。- オーバーライド:
- クラス
MessagingGatewaySupport
のdoStop
isClientMode
public boolean isClientMode()- 次で指定:
- インターフェース
ClientModeCapable
のisClientMode
- 戻り値:
- isClientMode
setClientMode
public void setClientMode(boolean isClientMode) - パラメーター:
isClientMode
- 設定する isClientMode
getRetryInterval
public long getRetryInterval()- 戻り値:
- retryInterval
setRetryInterval
public void setRetryInterval(long retryInterval) 再試行間隔を構成します。デフォルトはDEFAULT_RETRY_INTERVAL
です。- パラメーター:
retryInterval
- 設定する retryInterval
isClientModeConnected
public boolean isClientModeConnected()- 次で指定:
- インターフェース
ClientModeCapable
のisClientModeConnected
- 戻り値:
- エンドポイントがクライアントモードで実行されている場合は true。
retryConnection
public void retryConnection()インターフェースからコピーされた説明:ClientModeCapable
すぐに接続の確立を試みてください。- 次で指定:
- インターフェース
ClientModeCapable
のretryConnection
beforeShutdown
public int beforeShutdown()インターフェースからコピーされた説明:OrderlyShutdownCapable
シャットダウンが始まる前に呼び出されます。実装は、新しいメッセージの受け入れを停止する必要があります。オプションで、処理中のアクティブなメッセージの数を返すことができます。- 次で指定:
- インターフェース
OrderlyShutdownCapable
のbeforeShutdown
- 戻り値:
- 使用可能な場合、アクティブなメッセージの数。
afterShutdown
public int afterShutdown()インターフェースからコピーされた説明:OrderlyShutdownCapable
スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。- 次で指定:
- インターフェース
OrderlyShutdownCapable
のafterShutdown
- 戻り値:
- 使用可能な場合、アクティブなメッセージの数。