Class WebFluxInboundEndpoint

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.gateway.MessagingGatewaySupport

org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

org.springframework.integration.webflux.inbound.WebFluxInboundEndpoint

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ComponentSourceAware, ExpressionCapable, OrderlyShutdownCapable, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, WebHandler

public class WebFluxInboundEndpoint
extends BaseHttpInboundEndpoint
implements WebHandler

A MessagingGatewaySupport implementation for Spring WebFlux HTTP requests execution.

Since:

5.0

Author:

Artem Bilan, Gary Russell, Ngoc Nhan

See Also:

• HandlerResultHandlerSupport
• EnableWebFlux

Nested Class Summary

Nested classes/interfaces inherited from class MessagingGatewaySupport

MessagingGatewaySupport.ConvertingMessagingTemplate

Nested classes/interfaces inherited from interface IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class BaseHttpInboundEndpoint

activeCount, JAXB_PRESENT, NON_READABLE_BODY_HTTP_METHODS, ROME_TOOLS_PRESENT

Fields inherited from class MessagingGatewaySupport

messagingTemplate

Fields inherited from class AbstractEndpoint

lifecycleLock

Fields inherited from class IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
WebFluxInboundEndpoint()
WebFluxInboundEndpoint(boolean expectReply)

Method Summary

Modifier and Type	Method	Description
String	getComponentType()
reactor.core.publisher.Mono<Void>	handle(ServerWebExchange exchange)
void	setCodecConfigurer(ServerCodecConfigurer codecConfigurer)	A ServerCodecConfigurer for the request readers and response writers.
void	setReactiveAdapterRegistry(ReactiveAdapterRegistry adapterRegistry)	A registry of adapters to adapt a Reactive Streams Publisher to/from.
void	setRequestedContentTypeResolver(RequestedContentTypeResolver requestedContentTypeResolver)	A strategy to resolve the requested media types for a ServerWebExchange.

Methods inherited from class BaseHttpInboundEndpoint

afterShutdown, beforeShutdown, createEvaluationContext, evaluateHttpStatus, getCrossOrigin, getExtractReplyPayload, getHeaderExpressions, getHeaderMapper, getIntegrationPatternType, getPayloadExpression, getRequestMapping, getRequestPayloadType, getStatusCodeExpression, getValidator, isExpectReply, isReadable, onInit, resolveHttpStatusFromHeaders, setCrossOrigin, setExtractReplyPayload, setHeaderExpressions, setHeaderMapper, setPayloadExpression, setRequestMapping, setRequestPayloadType, setRequestPayloadTypeClass, setStatusCodeExpression, setStatusCodeExpressionString, setValidator, validate

Methods inherited from class MessagingGatewaySupport

buildErrorMessage, buildSendTimer, destroy, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getManagedName, getManagedType, getOverrides, getReplyChannel, getRequestChannel, getRequestChannelName, isLoggingEnabled, isObserved, receive, receive, receiveMessage, receiveMessage, registerMetricsCaptor, registerObservationRegistry, registerReplyMessageCorrelatorIfNecessary, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, sendTimer, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setErrorOnTimeout, setLoggingEnabled, setManagedName, setManagedType, setObservationConvention, setReceiverObservationConvention, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrack

Methods inherited from class AbstractEndpoint

doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

Methods inherited from class 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

Methods inherited from class Object

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

Methods inherited from interface IntegrationManagement

getThisAs

Methods inherited from interface NamedComponent

getBeanName, getComponentName

Methods inherited from interface SmartLifecycle

isPauseable

Constructor Details

WebFluxInboundEndpoint

public WebFluxInboundEndpoint()

WebFluxInboundEndpoint

public WebFluxInboundEndpoint(boolean expectReply)

Method Details

setCodecConfigurer

public void setCodecConfigurer(ServerCodecConfigurer codecConfigurer)

A ServerCodecConfigurer for the request readers and response writers. By default, the ServerCodecConfigurer.create() factory is used.

Parameters:

codecConfigurer - the ServerCodecConfigurer to use.

setRequestedContentTypeResolver

public void setRequestedContentTypeResolver(RequestedContentTypeResolver requestedContentTypeResolver)

A strategy to resolve the requested media types for a ServerWebExchange. A HeaderContentTypeResolver is used by default.

Parameters:

requestedContentTypeResolver - the RequestedContentTypeResolver to use.

setReactiveAdapterRegistry

public void setReactiveAdapterRegistry(ReactiveAdapterRegistry adapterRegistry)

A registry of adapters to adapt a Reactive Streams Publisher to/from.

Parameters:

adapterRegistry - the ReactiveAdapterRegistry to use.

getComponentType

public String getComponentType()

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class BaseHttpInboundEndpoint

handle

public reactor.core.publisher.Mono<Void> handle(ServerWebExchange exchange)

Specified by:

handle in interface WebHandler