クラス MulticastSendingMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.ip.udp.outbound.AbstractInternetProtocolSendingMessageHandler
org.springframework.integration.ip.udp.outbound.UnicastSendingMessageHandler
org.springframework.integration.ip.udp.outbound.MulticastSendingMessageHandler
実装されているすべてのインターフェース:
RunnableSE、org.reactivestreams.Subscriber<Message<?>>、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、IntegrationPattern、CommonSocketOptions、NamedComponent、IntegrationManagement、ManageableLifecycle、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>
既知の直属サブクラス
MulticastSendingMessageHandler
public class MulticastSendingMessageHandler extends UnicastSendingMessageHandler
メッセージを UDP データグラムパケットにマップし、それを指定されたマルチキャストアドレス (224.0.0.0 から 239.255.255.255) とポートに送信する MessageHandler 実装。

このクラスとそのスーパークラスとの唯一の違いは、成功を判定するために必要な確認応答の数を指定できるかどうかです。

導入:
2.0
作成者:
Gary Russell, Artem Bilan, Christian Tzolov

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

    • MulticastSendingMessageHandler

      public MulticastSendingMessageHandler(StringSE address, int port)
      マルチキャストアドレス / ポートにデータを送信するための MulticastSendingMessageHandler を構築します。
      パラメーター:
      address - マルチキャストアドレス。
      port - ポート。

    • MulticastSendingMessageHandler

      public MulticastSendingMessageHandler(StringSE address, int port, boolean lengthCheck)
      マルチキャストアドレス / ポートにデータを送信するための MulticastSendingMessageHandler を構築し、lengthCheck オプションの設定を有効にします (設定されている場合、長さがパケットの先頭に付加され、宛先でチェックされます)。
      パラメーター:
      address - マルチキャストアドレス。
      port - ポート。
      lengthCheck - lengthCheck オプションを有効にします。

    • MulticastSendingMessageHandler

      public MulticastSendingMessageHandler(StringSE address, int port, boolean acknowledge, StringSE ackHost, int ackPort, int ackTimeout)
      マルチキャストアドレス / ポートにデータを送信するための MulticastSendingMessageHandler を構築し、宛先が受信確認を送信する確認応答オプションの設定を有効にします。
      パラメーター:
      address - マルチキャストアドレス。
      port - ポート。
      acknowledge - 謝辞が必要かどうか。
      ackHost - 確認応答の送信先となるホスト。確認応答が true の場合に必要です。
      ackPort - 確認応答の送信先のポート。確認応答が true の場合に必要です。
      ackTimeout - 確認応答を待機する時間（ミリ秒）。

    • MulticastSendingMessageHandler

      public MulticastSendingMessageHandler(StringSE address, int port, boolean lengthCheck, boolean acknowledge, StringSE ackHost, int ackPort, int ackTimeout)
      マルチキャストアドレス / ポートにデータを送信するための MulticastSendingMessageHandler を構築し、宛先が受信確認を送信する確認応答オプションの設定を有効にします。
      パラメーター:
      address - マルチキャストアドレス。
      port - ポート。
      lengthCheck - lengthCheck オプションを有効にします。
      acknowledge - 謝辞が必要かどうか。
      ackHost - 確認応答の送信先となるホスト。確認応答が true の場合に必要です。
      ackPort - 確認応答の送信先のポート。確認応答が true の場合に必要です。
      ackTimeout - 確認応答を待機する時間（ミリ秒）。

    • MulticastSendingMessageHandler

      public MulticastSendingMessageHandler(Expression destinationExpression)
      宛先 SpEL 式に基づいて MulticastSendingMessageHandler を構築し、実行時に requestMessage に対してターゲット宛先を決定します。
      パラメーター:
      destinationExpression - 実行時にターゲットの宛先を評価するための SpEL 式。StringSE、URISE、SocketAddressSE に評価する必要があります。
      導入:
      5.0

    • MulticastSendingMessageHandler

      public MulticastSendingMessageHandler(StringSE destinationExpression)
      宛先 SpEL 式に基づいて MulticastSendingMessageHandler を構築し、実行時に requestMessage に対してターゲット宛先を決定します。
      パラメーター:
      destinationExpression - 実行時にターゲットの宛先を評価するための SpEL 式。StringSE、URISE、SocketAddressSE に評価する必要があります。
      導入:
      5.0

  • メソッドの詳細

    • setMinAcksForSuccess

      public void setMinAcksForSuccess(int minAcksForSuccess)
      確認 = true の場合 ; 成功するために必要な ack の数。
      パラメーター:
      minAcksForSuccess - 成功を表す ack の最小数。

    • setTimeToLive

      public void setTimeToLive(int timeToLive)
      基になる MulticastSocketSE 時間を有効アセットに設定します。
      パラメーター:
      timeToLive - MulticastSocket.setTimeToLive(int)SE

    • setLocalAddress

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

    • getSocket

      protected DatagramSocketSE getSocket() throws IOExceptionSE
      オーバーライド:
      クラス UnicastSendingMessageHandler の getSocket 
      例外:
      IOExceptionSE