public class ReactiveRequestHandlerAdvice extends ObjectSE implements MethodInterceptor
Mono を生成するメッセージハンドラー用の MethodInterceptor。返される Mono は、提供された replyCustomizer BiFunctionSE をコンテキストとしてリクエストメッセージとともに呼び出す Mono.transform(java.util.function.Function) オペレーターを介してカスタマイズされます。カスタマイズでは、Mono.timeout(java.time.Duration)、Mono.retry()、Mono.tag(java.lang.String, java.lang.String) などのサポートするリアクティブオペレータを使用することを前提としています。Mono.transform(java.util.function.Function) は、リアクティブサーキットブレーカーなどのさらなるカスタマイズにも使用できます。| コンストラクターと説明 |
|---|
ReactiveRequestHandlerAdvice(java.util.function.BiFunctionSE<Message<?>,reactor.core.publisher.Mono<?>,org.reactivestreams.Publisher<?>> replyCustomizer) 提供されている BiFunctionSE カスタマイザーに基づいてアドバイスをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ObjectSE | invoke(MethodInvocation invocation) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic ReactiveRequestHandlerAdvice(java.util.function.BiFunctionSE<Message<?>,reactor.core.publisher.Mono<?>,org.reactivestreams.Publisher<?>> replyCustomizer)
BiFunctionSE カスタマイザーに基づいてアドバイスをインスタンス化します。replyCustomizer - 生成された Mono をカスタマイズするための BiFunctionSE。public final ObjectSE invoke(MethodInvocation invocation) throws ThrowableSE
MethodInterceptor の invoke ThrowableSE