org.springframework.integration.http.inbound

Class ReactiveHttpInboundEndpoint

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.http.inbound.ReactiveHttpInboundEndpoint

All Implemented Interfaces:

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

public class ReactiveHttpInboundEndpoint
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

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

Constructor Summary

Constructors

Constructor and Description
ReactiveHttpInboundEndpoint()
ReactiveHttpInboundEndpoint(boolean expectReply)

Method Summary

Modifier and Type	Method and Description
String	getComponentType() Subclasses may implement this method to provide component type information.
reactor.core.publisher.Mono<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(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, 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

doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, 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, 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

Constructor Detail

ReactiveHttpInboundEndpoint

public ReactiveHttpInboundEndpoint()

ReactiveHttpInboundEndpoint

public ReactiveHttpInboundEndpoint(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(ReactiveAdapterRegistry adapterRegistry)

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

Parameters:

adapterRegistry - the ReactiveAdapterRegistry to use.

getComponentType

public 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 Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class BaseHttpInboundEndpoint

Throws:

Exception - Any exception.

handle

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

Specified by:

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