クラス TcpReceivingChannelAdapter

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.ip.tcp.inbound.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 void onMessage(Message<?> message)
      インターフェースからコピーされた説明: TcpListener
      新しいメッセージが到着したときに TCPConnection によって呼び出されます。
      次で指定:
      インターフェース TcpListener 内の onMessage 
      パラメーター:
      message - メッセージ。

    • 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()
      次で指定:
      インターフェース NamedComponent 内の getComponentType 
      オーバーライド:
      クラス MessageProducerSupport の getComponentType 

    • getClientConnectionFactory

      protected @Nullable ConnectionFactory getClientConnectionFactory()
      戻り値:
      clientConnectionFactory

    • getServerConnectionFactory

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