クラス StreamRetryOperationsInterceptorFactoryBean
java.lang.ObjectSE
org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
org.springframework.rabbit.stream.retry.StreamRetryOperationsInterceptorFactoryBean
- 実装されたすべてのインターフェース:
FactoryBean<Advice>
public class StreamRetryOperationsInterceptorFactoryBean
extends StatelessRetryOperationsInterceptorFactoryBean
ネイティブストリームメッセージを消費するときに
StreamListenerContainer で使用するステートレス再試行インターセプターを作成するための便利なファクトリ Bean により、リスナーが失敗したときのコンテナーの動作を大幅に制御できます。再試行回数または試行間のバックオフを制御するには、カスタマイズされた RetryTemplate を提供します。ステートレスな再試行は、リスナーを副作用なしで障害の間に繰り返し呼び出すことができる場合に適しています。ステートレスな再試行のセマンティクスは、再試行が使い果たされるまでリスナー例外がコンテナーに伝搬されないことを意味します。再試行が使い果たされると、StreamMessageRecoverer が提供されている場合はそれを使用して処理できます。- 作成者:
- Gary Russell
- 関連事項:
RetryOperations.execute(org.springframework.retry.RetryCallback,org.springframework.retry.RecoveryCallback)
フィールドサマリー
クラス org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean から継承されたフィールド
loggerインターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEコンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected org.springframework.retry.interceptor.MethodInvocationRecoverer<?>voidsetMessageRecoverer(MessageRecoverer messageRecoverer) voidsetStreamMessageRecoverer(StreamMessageRecoverer messageRecoverer) 再試行が使い果たされたときに呼び出すStreamMessageRecovererを設定します。クラス org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean から継承されたメソッド
getObject, getObjectType, isSingleton, recoverクラス org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean から継承されたメソッド
getMessageRecoverer, getRetryOperations, setRetryOperations
コンストラクターの詳細
StreamRetryOperationsInterceptorFactoryBean
public StreamRetryOperationsInterceptorFactoryBean()
メソッドの詳細
createRecoverer
protected org.springframework.retry.interceptor.MethodInvocationRecoverer<?> createRecoverer()- オーバーライド:
- クラス
StatelessRetryOperationsInterceptorFactoryBeanのcreateRecoverer
setStreamMessageRecoverer
再試行が使い果たされたときに呼び出すStreamMessageRecovererを設定します。- パラメーター:
messageRecoverer- 回復者。
setMessageRecoverer
- オーバーライド:
- クラス
AbstractRetryOperationsInterceptorFactoryBeanのsetMessageRecoverer