クラス TcpReceivingChannelAdapter

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ComponentSourceAware、ExpressionCapable、OrderlyShutdownCapable、MessageProducer、IntegrationPattern、ClientModeCapable、TcpListener、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
public class TcpReceivingChannelAdapter extends MessageProducerSupport implements TcpListener, ClientModeCapable, OrderlyShutdownCapable
TcpConnection を使用してデータを受信する Tcp 受信チャネルアダプター - 接続ファクトリがサーバーファクトリである場合、このリスナーが接続を所有します。クライアントファクトリの場合、送信者が接続を所有します。
導入:
2.0
作成者:
Gary Russell, Artem Bilan

  • コンストラクターの詳細

    • TcpReceivingChannelAdapter

      public TcpReceivingChannelAdapter()

  • メソッドの詳細

    • onMessage

      public boolean onMessage(Message<?> message)
      インターフェースからコピーされた説明: TcpListener
      新しいメッセージが到着したときに TCPConnection によって呼び出されます。
      次で指定:
      インターフェース TcpListener の onMessage 
      パラメーター:
      message - メッセージ。
      戻り値:
      メッセージがインターセプトされた場合は true

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス MessageProducerSupport の onInit 

    • doStart

      protected void doStart()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。
      オーバーライド:
      クラス MessageProducerSupport の doStart 

    • doStop

      protected void doStop()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
      オーバーライド:
      クラス MessageProducerSupport の doStop 

    • setConnectionFactory

      public void setConnectionFactory(AbstractConnectionFactory connectionFactory)
      クライアントまたはサーバー接続ファクトリを設定します。この場合（受信アダプター）、ファクトリがクライアント接続ファクトリである場合、ソケットは送信チャネルアダプターによって所有され、このアダプターは応答の受信に使用されます。
      パラメーター:
      connectionFactory - 設定する connectionFactory

    • isListening

      public boolean isListening()

    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponent の getComponentType 
      オーバーライド:
      クラス IntegrationObjectSupport の getComponentType 

    • getClientConnectionFactory

      protected ConnectionFactory getClientConnectionFactory()
      戻り値:
      clientConnectionFactory

    • getServerConnectionFactory

      protected ConnectionFactory getServerConnectionFactory()
      戻り値:
      serverConnectionFactory

    • 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)
      パラメーター:
      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 
      戻り値:
      使用可能な場合、アクティブなメッセージの数。