パッケージ org.springframework.amqp.rabbit.retry

クラス RepublishMessageRecovererWithConfirms

java.lang.ObjectSE
org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
org.springframework.amqp.rabbit.retry.RepublishMessageRecovererWithConfirms
実装されたすべてのインターフェース:
MessageRecoverer
public class RepublishMessageRecovererWithConfirms extends RepublishMessageRecoverer
RepublishMessageRecoverer サポートパブリッシャーが確認して返します。
導入:
2.3.3
作成者:
Gary Russell, Artem Bilan

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

    • RepublishMessageRecovererWithConfirms

      public RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, CachingConnectionFactory.ConfirmType confirmType)
      提供されたテンプレートを使用して、提供された確認型でメッセージを公開します。テンプレートとその接続ファクトリは、confirm 型をサポートするように適切に構成する必要があります。
      パラメーター:
      errorTemplate - テンプレート。
      confirmType - 確認型。

    • RepublishMessageRecovererWithConfirms

      public RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, StringSE errorExchange, CachingConnectionFactory.ConfirmType confirmType)
      提供されたテンプレートを使用して、提供された確認型のメッセージを、デフォルトのルーティングキーを使用して提供された Exchange に発行します。テンプレートとその接続ファクトリは、confirm 型をサポートするように適切に構成する必要があります。
      パラメーター:
      errorTemplate - テンプレート。
      confirmType - 確認型。
      errorExchange - 交換。

    • RepublishMessageRecovererWithConfirms

      public RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, StringSE errorExchange, StringSE errorRoutingKey, CachingConnectionFactory.ConfirmType confirmType)
      提供されたテンプレートを使用して、提供されたルーティングキーを使用して、提供された確認型のメッセージを提供された Exchange に発行します。テンプレートとその接続ファクトリは、confirm 型をサポートするように適切に構成する必要があります。
      パラメーター:
      errorTemplate - テンプレート。
      confirmType - 確認型。
      errorExchange - 交換。
      errorRoutingKey - ルーティングキー。

    • RepublishMessageRecovererWithConfirms

      public RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, @Nullable Expression errorExchange, @Nullable Expression errorRoutingKey, CachingConnectionFactory.ConfirmType confirmType)
      提供されたテンプレートを使用して、提供されたルーティングキーを使用して、提供された確認型のメッセージを提供された Exchange に発行します。テンプレートとその接続ファクトリは、confirm 型をサポートするように適切に構成する必要があります。
      パラメーター:
      errorTemplate - テンプレート。
      confirmType - 確認型。
      errorExchange - 交換。
      errorRoutingKey - ルーティングキー。
      導入:
      3.1.2

  • メソッドの詳細

    • setConfirmTimeout

      public void setConfirmTimeout(long confirmTimeout)
      confirm タイムアウトを設定します。デフォルトは 10 秒です。
      パラメーター:
      confirmTimeout - タイムアウト。

    • doSend

      protected void doSend(@Nullable StringSE exchange, StringSE routingKey, Message message)
      クラスからコピーされた説明: RepublishMessageRecoverer
      メッセージを送信します。
      オーバーライド:
      クラス RepublishMessageRecoverer の doSend 
      パラメーター:
      exchange - テンプレートのデフォルトを使用する場合は exchange または null。
      routingKey - ルーティングキー。
      message - メッセージ。