クラス AbstractInternetProtocolReceivingChannelAdapter

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.ip.udp.inbound.AbstractInternetProtocolReceivingChannelAdapter
実装済みのインターフェース一覧:
RunnableSE, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle, ComponentSourceAware, ExpressionCapable, MessageProducer, IntegrationPattern, CommonSocketOptions, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, SchedulingAwareRunnable
既知の直属サブクラス
UnicastReceivingChannelAdapter
public abstract class AbstractInternetProtocolReceivingChannelAdapter extends MessageProducerSupport implements ApplicationEventPublisherAware, SchedulingAwareRunnable, CommonSocketOptions
受信 TCP/UDP チャネルアダプターの基本クラス。
導入:
2.0
作成者:
Mark Fisher, Gary Russell, Artem Bilan

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

    • AbstractInternetProtocolReceivingChannelAdapter

      public AbstractInternetProtocolReceivingChannelAdapter(int port)

  • 方法の詳細

    • getPort

      public int getPort()
      戻り値:
      このレシーバーがリッスンしているポート。

    • setSoTimeout

      public void setSoTimeout(int soTimeout)
      次で指定:
      インターフェース CommonSocketOptions 内の setSoTimeout 
      パラメーター:
      soTimeout - タイムアウト（ミリ秒単位）。
      関連事項:

    • getSoTimeout

      public int getSoTimeout()
      戻り値:
      soTimeout

    • setSoReceiveBufferSize

      public void setSoReceiveBufferSize(int soReceiveBufferSize)
      次で指定:
      インターフェース CommonSocketOptions 内の setSoReceiveBufferSize 
      パラメーター:
      soReceiveBufferSize - 受信バッファサイズ。
      関連事項:

    • getSoReceiveBufferSize

      public int getSoReceiveBufferSize()
      戻り値:
      soReceiveBufferSize

    • setReceiveBufferSize

      public void setReceiveBufferSize(int receiveBufferSize)

    • getReceiveBufferSize

      public int getReceiveBufferSize()
      戻り値:
      receiveBufferSize

    • isListening

      public boolean isListening()

    • setListening

      public void setListening(boolean listening)
      パラメーター:
      listening - セットを聞く

    • getLocalAddress

      public @Nullable StringSE getLocalAddress()

    • setLocalAddress

      public void setLocalAddress(StringSE localAddress)
      インターフェースからコピーされた説明: CommonSocketOptions
      マルチホームシステムでは、通信に使用されるネットワークインターフェースの IP アドレスを指定します。受信アダプターおよびゲートウェイの場合、受信接続用にリストされているインターフェースを指定します。省略した場合、エンドポイントは使用可能なすべてのアダプターをリッスンします。UDP マルチキャスト送信アダプターの場合、マルチキャストパケットの送信先のインターフェースを指定します。UDP ユニキャストおよびマルチキャストアダプターの場合、確認応答ソケットがバインドされるインターフェースを指定します。TCP 送信アダプターおよびゲートウェイには適用されません。
      次で指定:
      インターフェース CommonSocketOptions 内の setLocalAddress 
      パラメーター:
      localAddress - ローカルアドレス。

    • setPoolSize

      public void setPoolSize(int poolSize)

    • setTaskExecutor

      public void setTaskExecutor(ExecutorSE taskExecutor)

    • getTaskExecutor

      public @Nullable ExecutorSE getTaskExecutor()
      戻り値:
      taskExecutor

    • getApplicationEventPublisher

      protected ApplicationEventPublisher getApplicationEventPublisher()

    • setApplicationEventPublisher

      public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
      次で指定:
      インターフェース ApplicationEventPublisherAware 内の setApplicationEventPublisher 

    • doStart

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

    • checkTaskExecutor

      protected void checkTaskExecutor(StringSE threadName)
      何も指定されていない場合は、デフォルトのタスクエグゼキュータを作成します。
      パラメーター:
      threadName - スレッド名。

    • doStop

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