org.springframework.integration.webflux.inbound

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:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ExpressionCapable, OrderlyShutdownCapable, NamedComponent, IntegrationManagement, MessageSourceMetrics, TrackableComponent, org.springframework.web.server.WebHandler

public class WebFluxInboundEndpoint
extends BaseHttpInboundEndpoint
implements org.springframework.web.server.WebHandler

A MessagingGatewaySupport implementation for Spring WebFlux HTTP requests execution.

Since:

5.0

Author:

Artem Bilan

See Also:

HandlerResultHandlerSupport, EnableWebFlux

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

activeCount, expectReply, jaxb2Present, nonReadableBodyHttpMethods, romeToolsPresent

Fields inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

messagingTemplate

Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

lifecycleCondition, lifecycleLock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
WebFluxInboundEndpoint()
WebFluxInboundEndpoint(boolean expectReply)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
reactor.core.publisher.Mono<java.lang.Void>	handle(org.springframework.web.server.ServerWebExchange exchange)
protected void	onInit() Subclasses may implement this for initialization logic.
void	setCodecConfigurer(org.springframework.http.codec.ServerCodecConfigurer codecConfigurer) A ServerCodecConfigurer for the request readers and response writers.
void	setReactiveAdapterRegistry(org.springframework.core.ReactiveAdapterRegistry adapterRegistry) A registry of adapters to adapt a Reactive Streams Publisher to/from.
void	setRequestedContentTypeResolver(org.springframework.web.reactive.accept.RequestedContentTypeResolver requestedContentTypeResolver) A strategy to resolve the requested media types for a ServerWebExchange.

Methods inherited from class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

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

Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, getReplyChannel, getRequestChannel, isCountsEnabled, isLoggingEnabled, receive, receive, receiveMessage, receiveMessage, registerReplyMessageCorrelatorIfNecessary, reset, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, setCountsEnabled, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setLoggingEnabled, setManagedName, setManagedType, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Methods inherited from interface org.springframework.integration.support.management.MessageSourceMetrics

setCounter

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

registerMetricsCaptor

Constructor Detail

WebFluxInboundEndpoint

public WebFluxInboundEndpoint()

WebFluxInboundEndpoint

public WebFluxInboundEndpoint(boolean expectReply)

Method Detail

setCodecConfigurer

public void setCodecConfigurer(org.springframework.http.codec.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(org.springframework.web.reactive.accept.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(org.springframework.core.ReactiveAdapterRegistry adapterRegistry)

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

Parameters:

adapterRegistry - the ReactiveAdapterRegistry to use.

getComponentType

public java.lang.String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class BaseHttpInboundEndpoint

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class BaseHttpInboundEndpoint

Throws:

java.lang.Exception - Any exception.

handle

public reactor.core.publisher.Mono<java.lang.Void> handle(org.springframework.web.server.ServerWebExchange exchange)

Specified by:

handle in interface org.springframework.web.server.WebHandler