クラス 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
- 関連事項:
ネストされたクラスのサマリー
クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたネストクラス / インターフェース
AbstractReplyProducingMessageHandler.RequestHandler
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドのサマリー
クラス org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler から継承されたフィールド
uriFactory
クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド
messagingTemplate
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
コンストラクターの概要
コンストラクターコンストラクター説明指定された URI にリクエストを送信するハンドラーを作成します。WebFluxRequestExecutingMessageHandler
(StringSE uri, WebClient webClient) 提供された WebClient を使用して、提供された URI にリクエストを送信するハンドラーを作成します。指定された URI にリクエストを送信するハンドラーを作成します。WebFluxRequestExecutingMessageHandler
(Expression uriExpression) 提供された URI 式にリクエストを送信するハンドラーを作成します。WebFluxRequestExecutingMessageHandler
(Expression uriExpression, WebClient webClient) 提供された WebClient を使用して、提供された URI にリクエストを送信するハンドラーを作成します。メソッドのサマリー
修飾子と型メソッド説明protected final void
doInit()
protected ObjectSE
exchange
(ObjectSE uri, HttpMethod httpMethod, HttpEntity<?> httpRequest, ObjectSE expectedResponseType, Message<?> requestMessage, MapSE<StringSE, ?> uriVariables) サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。void
setAttributeVariablesExpression
(Expression attributeVariablesExpression) webclient リクエスト属性に追加されるリクエスト属性を評価する式を設定します。void
setBodyExtractor
(BodyExtractor<?, ? super ClientHttpResponse> bodyExtractor) void
setEncodingMode
(DefaultUriBuilderFactory.EncodingMode encodingMode) 使用するエンコードモードを設定します。void
setPublisherElementType
(ClassSE<?> publisherElementType) リクエストPublisher
要素の型を構成します。void
setPublisherElementTypeExpression
(Expression publisherElementTypeExpression) 実行時にリクエストメッセージに対してリクエストPublisher
要素型を評価するように SpEL 式を構成します。void
setReplyPayloadToFlux
(boolean replyPayloadToFlux) レスポンスペイロードをレスポンス本文からのFlux
として使用するか、レスポンス本文からのMono
からの解決済み値として使用するかを識別するブールフラグ。クラス org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler から継承されたメソッド
evaluateTypeFromExpression, getIntegrationPatternType, getReply, handleRequestMessage, isExpectReply, mapHeaders, setCharset, setExpectedResponseType, setExpectedResponseTypeExpression, setExpectReply, setExtractPayload, setExtractResponseBody, setHeaderMapper, setHttpMethod, setHttpMethodExpression, setTransferCookies, setTrustedSpel, setUriVariableExpressions, setUriVariablesExpression
クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたメソッド
doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, setupMessageProcessor, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド
handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention
クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド
buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
クラス org.springframework.integration.context.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
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContext
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
WebFluxRequestExecutingMessageHandler
指定された URI にリクエストを送信するハンドラーを作成します。- パラメーター:
uri
- URI。
WebFluxRequestExecutingMessageHandler
指定された URI にリクエストを送信するハンドラーを作成します。- パラメーター:
uri
- URI。
WebFluxRequestExecutingMessageHandler
提供された URI 式にリクエストを送信するハンドラーを作成します。- パラメーター:
uriExpression
- URI 式。
WebFluxRequestExecutingMessageHandler
提供された WebClient を使用して、提供された URI にリクエストを送信するハンドラーを作成します。- パラメーター:
uri
- URI。webClient
- 使用する WebClient。
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
クラスからコピーされた説明:IntegrationObjectSupport
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。- 次で指定:
- インターフェース
NamedComponent
のgetComponentType
- オーバーライド:
- クラス
MessageHandlerSupport
のgetComponentType
doInit
protected final void doInit()- オーバーライド:
- クラス
AbstractHttpRequestExecutingMessageHandler
のdoInit
exchange
@Nullable protected ObjectSE exchange(ObjectSE uri, HttpMethod httpMethod, HttpEntity<?> httpRequest, ObjectSE expectedResponseType, Message<?> requestMessage, MapSE<StringSE, ?> uriVariables) - 次で指定:
- クラス
AbstractHttpRequestExecutingMessageHandler
のexchange