クラス RepublishMessageRecovererWithConfirms
java.lang.ObjectSE
org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
org.springframework.amqp.rabbit.retry.RepublishMessageRecovererWithConfirms
- 実装されたすべてのインターフェース:
MessageRecoverer
RepublishMessageRecoverer
サポートパブリッシャーが確認して返します。- 導入:
- 2.3.3
- 作成者:
- Gary Russell, Artem Bilan
フィールドサマリー
クラス org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer から継承されたフィールド
DEFAULT_FRAME_MAX_HEADROOM, errorExchangeNameExpression, errorRoutingKeyExpression, errorTemplate, evaluationContext, logger, X_EXCEPTION_MESSAGE, X_EXCEPTION_STACKTRACE, X_ORIGINAL_EXCHANGE, X_ORIGINAL_ROUTING_KEY
コンストラクターのサマリー
コンストラクター説明RepublishMessageRecovererWithConfirms
(RabbitTemplate errorTemplate, StringSE errorExchange, StringSE errorRoutingKey, CachingConnectionFactory.ConfirmType confirmType) 提供されたテンプレートを使用して、提供されたルーティングキーを使用して、提供された確認型のメッセージを提供された Exchange に発行します。RepublishMessageRecovererWithConfirms
(RabbitTemplate errorTemplate, StringSE errorExchange, CachingConnectionFactory.ConfirmType confirmType) 提供されたテンプレートを使用して、提供された確認型のメッセージを、デフォルトのルーティングキーを使用して提供された Exchange に発行します。RepublishMessageRecovererWithConfirms
(RabbitTemplate errorTemplate, CachingConnectionFactory.ConfirmType confirmType) 提供されたテンプレートを使用して、提供された確認型でメッセージを公開します。RepublishMessageRecovererWithConfirms
(RabbitTemplate errorTemplate, Expression errorExchange, Expression errorRoutingKey, CachingConnectionFactory.ConfirmType confirmType) 提供されたテンプレートを使用して、提供されたルーティングキーを使用して、提供された確認型のメッセージを提供された Exchange に発行します。メソッドのサマリー
修飾子と型メソッド説明protected void
メッセージを送信します。void
setConfirmTimeout
(long confirmTimeout) confirm
タイムアウトを設定します。デフォルトは 10 秒です。クラス org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer から継承されたメソッド
additionalHeaders, errorRoutingKeyPrefix, frameMaxHeadroom, getDeliveryMode, getErrorRoutingKeyPrefix, getStackTraceAsString, prefixedOriginalRoutingKey, recover, setDeliveryMode, setErrorRoutingKeyPrefix
コンストラクターの詳細
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
クラスからコピーされた説明:RepublishMessageRecoverer
メッセージを送信します。- オーバーライド:
- クラス
RepublishMessageRecoverer
のdoSend
- パラメーター:
exchange
- テンプレートのデフォルトを使用する場合は exchange または null。routingKey
- ルーティングキー。message
- メッセージ。