クラス WebFluxRequestExecutingMessageHandler
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler
org.springframework.integration.webflux.outbound.WebFluxRequestExecutingMessageHandler
- 実装済みのインターフェース一覧:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ComponentSourceAware, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
public class WebFluxRequestExecutingMessageHandler
extends AbstractHttpRequestExecutingMessageHandler
リアクティブ
WebClient インスタンスに委譲することによって HTTP リクエストを実行する MessageHandler 実装。- 導入:
- 5.0
- 作成者:
- Shiliang Li, Artem Bilan, Gary Russell, David Graff, Jatin Saxena, Ngoc Nhan
- 関連事項:
ネストされたクラスの概要
クラス AbstractReplyProducingMessageHandler から継承されたネストクラス / インターフェース
AbstractReplyProducingMessageHandler.RequestHandlerインターフェース IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス AbstractHttpRequestExecutingMessageHandler から継承されたフィールド
uriFactoryクラス AbstractMessageProducingHandler から継承されたフィールド
messagingTemplateクラス IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEインターフェース Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCEコンストラクター概要
コンストラクターコンストラクター説明指定された URI にリクエストを送信するハンドラーを作成します。WebFluxRequestExecutingMessageHandler(StringSE uri, @Nullable WebClient webClient) 提供された WebClient を使用して、提供された URI にリクエストを送信するハンドラーを作成します。指定された URI にリクエストを送信するハンドラーを作成します。WebFluxRequestExecutingMessageHandler(Expression uriExpression) 提供された URI 式にリクエストを送信するハンドラーを作成します。WebFluxRequestExecutingMessageHandler(Expression uriExpression, @Nullable WebClient webClient) 提供された WebClient を使用して、提供された URI にリクエストを送信するハンドラーを作成します。方法の概要
修飾子と型メソッド説明protected final voiddoInit()protected @Nullable ObjectSEexchange(ObjectSE uri, HttpMethod httpMethod, HttpEntity<?> httpRequest, ObjectSE expectedResponseType, Message<?> requestMessage, MapSE<StringSE, ?> uriVariables) voidsetAttributeVariablesExpression(Expression attributeVariablesExpression) webclient リクエスト属性に追加されるリクエスト属性を評価する式を設定します。voidsetBodyExtractor(BodyExtractor<?, ? super ClientHttpResponse> bodyExtractor) voidsetEncodingMode(DefaultUriBuilderFactory.EncodingMode encodingMode) 使用するエンコードモードを設定します。voidsetPublisherElementType(ClassSE<?> publisherElementType) リクエストPublisher要素の型を構成します。voidsetPublisherElementTypeExpression(Expression publisherElementTypeExpression) 実行時にリクエストメッセージに対してリクエストPublisher要素型を評価するように SpEL 式を構成します。voidsetReplyPayloadToFlux(boolean replyPayloadToFlux) レスポンスペイロードをレスポンス本文からのFluxとして使用するか、レスポンス本文からのMonoからの解決済み値として使用するかを識別するブールフラグ。クラス AbstractHttpRequestExecutingMessageHandler から継承されたメソッド
evaluateTypeFromExpression, getIntegrationPatternType, getReply, handleRequestMessage, isExpectReply, mapHeaders, setCharset, setExpectedResponseType, setExpectedResponseTypeExpression, setExpectReply, setExtractPayload, setExtractResponseBody, setHeaderMapper, setHttpMethod, setHttpMethodExpression, setTransferCookies, setTrustedSpel, setUriVariableExpressions, setUriVariablesExpressionクラス AbstractReplyProducingMessageHandler から継承されたメソッド
doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyクラス AbstractMessageProducingHandler から継承されたメソッド
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, setupMessageProcessor, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadersクラス AbstractMessageHandler から継承されたメソッド
handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConventionクラス MessageHandlerSupport から継承されたメソッド
buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackクラス IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContextインターフェース IntegrationManagement から継承されたメソッド
getThisAsインターフェース NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
WebFluxRequestExecutingMessageHandler
指定された URI にリクエストを送信するハンドラーを作成します。- パラメーター:
uri- URI。
WebFluxRequestExecutingMessageHandler
指定された URI にリクエストを送信するハンドラーを作成します。- パラメーター:
uri- URI。
WebFluxRequestExecutingMessageHandler
提供された URI 式にリクエストを送信するハンドラーを作成します。- パラメーター:
uriExpression- URI 式。
WebFluxRequestExecutingMessageHandler
WebFluxRequestExecutingMessageHandler
public WebFluxRequestExecutingMessageHandler(Expression uriExpression, @Nullable WebClient webClient) 提供された WebClient を使用して、提供された URI にリクエストを送信するハンドラーを作成します。- パラメーター:
uriExpression- メッセージオブジェクトおよびBeanFactoryに対して解決できる SpEL 式。webClient- 使用する WebClient。
方法の詳細
setEncodingMode
クラスからコピーされた説明:AbstractHttpRequestExecutingMessageHandler使用するエンコードモードを設定します。デフォルトでは、これはDefaultUriBuilderFactory.EncodingMode.TEMPLATE_AND_VALUESに設定されています。より複雑なシナリオでは、外部から提供されたRestTemplateでUriTemplateHandlerを構成することを検討してください。- オーバーライド:
- クラス
AbstractHttpRequestExecutingMessageHandlerのsetEncodingMode - パラメーター:
encodingMode- uri エンコーディングに使用するモード
setReplyPayloadToFlux
public void setReplyPayloadToFlux(boolean replyPayloadToFlux) レスポンスペイロードをレスポンス本文からのFluxとして使用するか、レスポンス本文からのMonoからの解決済み値として使用するかを識別するブールフラグ。デフォルトはfalseです - 単純な値がダウンストリームにプッシュされます。expectedResponseTypeが構成されている場合は意味があります。- パラメーター:
replyPayloadToFlux- 応答ペイロードをFluxまたはMonoからの値として表します。- 導入:
- 5.0.1
- 関連事項:
setBodyExtractor
- パラメーター:
bodyExtractor- 使用するBodyExtractor。- 導入:
- 5.0.1
- 関連事項:
setPublisherElementType
リクエストPublisher要素の型を構成します。- パラメーター:
publisherElementType- リクエストPublisher要素の型。- 導入:
- 5.2
- 関連事項:
setPublisherElementTypeExpression
実行時にリクエストメッセージに対してリクエストPublisher要素型を評価するように SpEL 式を構成します。- パラメーター:
publisherElementTypeExpression- リクエストPublisher要素の型を評価する式。- 導入:
- 5.2
- 関連事項:
setAttributeVariablesExpression
webclient リクエスト属性に追加されるリクエスト属性を評価する式を設定します。- パラメーター:
attributeVariablesExpression- リクエスト属性を評価する式。- 導入:
- 6.0
- 関連事項:
getComponentType
- 次で指定:
- インターフェース
NamedComponent内のgetComponentType - オーバーライド:
- クラス
MessageHandlerSupportのgetComponentType
doInit
protected final void doInit()- オーバーライド:
- クラス
AbstractHttpRequestExecutingMessageHandlerのdoInit
exchange
protected @Nullable ObjectSE exchange(ObjectSE uri, HttpMethod httpMethod, HttpEntity<?> httpRequest, ObjectSE expectedResponseType, Message<?> requestMessage, MapSE<StringSE, ?> uriVariables) - 次で指定:
- クラス
AbstractHttpRequestExecutingMessageHandlerのexchange