org.springframework.integration.webflux.dsl

Class WebFluxMessageHandlerSpec

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<T>

org.springframework.integration.dsl.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.MessageHandlerSpec<S,E>

org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>

org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<WebFluxRequestExecutingMessageHandler>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

public class WebFluxMessageHandlerSpec
extends BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>

The BaseHttpMessageHandlerSpec implementation for the WebFluxRequestExecutingMessageHandler.

Since:

5.0

Author:

Shiliang Li, Artem Bilan, Abhijit Sarkar, Gary Russell

See Also:

WebFluxRequestExecutingMessageHandler

Field Summary

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Method Summary

Modifier and Type	Method and Description
WebFluxMessageHandlerSpec	bodyExtractor(BodyExtractor<?,ClientHttpResponse> bodyExtractor) Specify a BodyExtractor as an alternative to the expectedResponseType to allow to get low-level access to the received ClientHttpResponse.
protected WebFluxMessageHandlerSpec	expectReply(boolean expectReply)
protected boolean	isClientSet()
WebFluxMessageHandlerSpec	replyPayloadToFlux(boolean replyPayloadToFlux) The boolean flag to identify if the reply payload should be as a Flux from the response body or as resolved value from the Mono of the response body.

Methods inherited from class org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec

charset, encodeUri, expectedResponseType, expectedResponseType, expectedResponseTypeExpression, expectedResponseTypeFunction, extractPayload, getComponentsToRegister, headerMapper, httpMethod, httpMethodExpression, httpMethodFunction, mappedRequestHeaders, mappedResponseHeaders, transferCookies, uriVariable, uriVariable, uriVariable, uriVariableExpressions, uriVariablesExpression, uriVariablesExpression, uriVariablesFunction

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

replyPayloadToFlux

public WebFluxMessageHandlerSpec replyPayloadToFlux(boolean replyPayloadToFlux)

The boolean flag to identify if the reply payload should be as a Flux from the response body or as resolved value from the Mono of the response body. Defaults to false - simple value is pushed downstream. Makes sense when expectedResponseType is configured.

Parameters:

replyPayloadToFlux - represent reply payload as a Flux or as a value from the Mono.

Returns:

the spec

Since:

5.0.1

See Also:

WebFluxRequestExecutingMessageHandler.setReplyPayloadToFlux(boolean)

bodyExtractor

public WebFluxMessageHandlerSpec bodyExtractor(BodyExtractor<?,ClientHttpResponse> bodyExtractor)

Specify a BodyExtractor as an alternative to the expectedResponseType to allow to get low-level access to the received ClientHttpResponse.

Parameters:

bodyExtractor - the BodyExtractor to use.

Returns:

the spec

Since:

5.0.1

See Also:

WebFluxRequestExecutingMessageHandler.setBodyExtractor(BodyExtractor)

isClientSet

protected boolean isClientSet()

Specified by:

isClientSet in class BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>

expectReply

protected WebFluxMessageHandlerSpec expectReply(boolean expectReply)

Overrides:

expectReply in class BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec,WebFluxRequestExecutingMessageHandler>