クラス MulticastSendingMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.ip.AbstractInternetProtocolSendingMessageHandler
org.springframework.integration.ip.udp.UnicastSendingMessageHandler
org.springframework.integration.ip.udp.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<?>>
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

  • メソッドの詳細

    • getSocket

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

    • 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 - ローカルアドレス。

    • convertAndSend

      protected void convertAndSend(Message<?> message) throws IOExceptionSE, URISyntaxExceptionSE
      オーバーライド:
      クラス UnicastSendingMessageHandler の convertAndSend 
      例外:
      IOExceptionSE
      URISyntaxExceptionSE