クラス 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。これにより、リスナーが失敗した場合のコンテナーの動作を詳細に制御できます。再試行回数や試行間のバックオフを制御するには、カスタマイズされた RetryOperations を指定します。ステートレス再試行は、リスナーが失敗と失敗の間に副作用なしで繰り返し呼び出される場合に適しています。ステートレス再試行のセマンティクスは、再試行回数が尽きるまでリスナー例外がコンテナーに伝播されないことを意味します。再試行回数が尽きた場合、StreamMessageRecoverer が提供されている場合は、それを使用して処理できます。- 作成者:
- Gary Russell, Stephane Nicoll
フィールドのサマリー
クラス org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean から継承されたフィールド
loggerインターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEコンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected @Nullable ObjectSErecover(@Nullable ObjectSE[] args, ThrowableSE cause) voidsetMessageRecoverer(MessageRecoverer messageRecoverer) voidsetStreamMessageRecoverer(StreamMessageRecoverer messageRecoverer) 再試行が使い果たされたときに呼び出すStreamMessageRecovererを設定します。クラス org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean から継承されたメソッド
getObject, getObjectTypeクラス org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean から継承されたメソッド
getMessageRecoverer, getRetryPolicy, setRetryPolicyクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.beans.factory.FactoryBean から継承されたメソッド
isSingleton
コンストラクターの詳細
StreamRetryOperationsInterceptorFactoryBean
public StreamRetryOperationsInterceptorFactoryBean()
メソッドの詳細
recover
- オーバーライド:
- クラス
StatelessRetryOperationsInterceptorFactoryBeanのrecover
setStreamMessageRecoverer
再試行が使い果たされたときに呼び出すStreamMessageRecovererを設定します。- パラメーター:
messageRecoverer- 回復者。
setMessageRecoverer
- オーバーライド:
- クラス
AbstractRetryOperationsInterceptorFactoryBeanのsetMessageRecoverer