クラス 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
フィールドサマリー
クラス org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer から継承されたフィールド
DEFAULT_FRAME_MAX_HEADROOM, errorExchangeName, errorRoutingKey, errorTemplate, logger, X_EXCEPTION_MESSAGE, X_EXCEPTION_STACKTRACE, X_ORIGINAL_EXCHANGE, X_ORIGINAL_ROUTING_KEY
コンストラクターのサマリー
コンストラクター コンストラクター 説明 RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, StringSE errorExchange, StringSE errorRoutingKey, CachingConnectionFactory.ConfirmType confirmType)提供されたテンプレートを使用して、提供された確認型のメッセージを、提供されたルーティングキーを使用して提供された交換に発行します。RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, StringSE errorExchange, CachingConnectionFactory.ConfirmType confirmType)提供されたテンプレートを使用して、提供された確認型のメッセージを、デフォルトのルーティングキーを使用して提供されたエクスチェンジにパブリッシュします。RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, CachingConnectionFactory.ConfirmType confirmType)提供されたテンプレートを使用して、提供された確認型でメッセージを公開します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 protected voiddoSend(StringSE exchange, StringSE routingKey, Message message)メッセージを送信します。voidsetConfirmTimeout(long confirmTimeout)確認タイムアウトを設定します。デフォルトは 10 秒です。クラス org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer から継承されたメソッド
additionalHeaders, errorRoutingKeyPrefix, frameMaxHeadroom, getDeliveryMode, getErrorRoutingKeyPrefix, recover, setDeliveryMode, setErrorRoutingKeyPrefix
コンストラクターの詳細
RepublishMessageRecovererWithConfirms
public RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, CachingConnectionFactory.ConfirmType confirmType)
提供されたテンプレートを使用して、提供された確認型でメッセージを公開します。テンプレートとその接続ファクトリは、確認型をサポートするように適切に構成する必要があります。- パラメーター:
errorTemplate- テンプレート。confirmType- 確認型。
RepublishMessageRecovererWithConfirms
public RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, StringSE errorExchange, CachingConnectionFactory.ConfirmType confirmType)
提供されたテンプレートを使用して、提供された確認型のメッセージを、デフォルトのルーティングキーを使用して提供されたエクスチェンジにパブリッシュします。テンプレートとその接続ファクトリは、確認型をサポートするように適切に構成する必要があります。- パラメーター:
errorTemplate- テンプレート。confirmType- 確認型。errorExchange- 交換。
RepublishMessageRecovererWithConfirms
public RepublishMessageRecovererWithConfirms(RabbitTemplate errorTemplate, StringSE errorExchange, StringSE errorRoutingKey, CachingConnectionFactory.ConfirmType confirmType)
提供されたテンプレートを使用して、提供された確認型のメッセージを、提供されたルーティングキーを使用して提供された交換に発行します。テンプレートとその接続ファクトリは、確認型をサポートするように適切に構成する必要があります。- パラメーター:
errorTemplate- テンプレート。confirmType- 確認型。errorExchange- 交換。errorRoutingKey- ルーティングキー。
メソッドの詳細
setConfirmTimeout
public void setConfirmTimeout(long confirmTimeout)
確認タイムアウトを設定します。デフォルトは 10 秒です。- パラメーター:
confirmTimeout- タイムアウト。
doSend
protected void doSend(@Nullable StringSE exchange, StringSE routingKey, Message message)
クラスからコピーされた説明:RepublishMessageRecovererメッセージを送信します。- オーバーライド:
- クラス
RepublishMessageRecovererのdoSend - パラメーター:
exchange- テンプレートのデフォルトを使用する場合は exchange または null。routingKey- ルーティングキー。message- メッセージ。