public class WebFluxInboundEndpoint
extends org.springframework.integration.http.inbound.BaseHttpInboundEndpoint
implements org.springframework.web.server.WebHandler
MessagingGatewaySupport
implementation for Spring WebFlux HTTP requests execution.HandlerResultHandlerSupport,
EnableWebFluxactiveCount, JAXB_PRESENT, NON_READABLE_BODY_HTTP_METHODS, ROME_TOOLS_PRESENTmessagingTemplatelifecycleCondition, lifecycleLockEXPRESSION_PARSER, logger| Constructor and Description |
|---|
WebFluxInboundEndpoint() |
WebFluxInboundEndpoint(boolean expectReply) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getComponentType() |
reactor.core.publisher.Mono<java.lang.Void> |
handle(org.springframework.web.server.ServerWebExchange exchange) |
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. |
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, validatebuildErrorMessage, buildSendTimer, destroy, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getManagedName, getManagedType, getOverrides, getReplyChannel, getRequestChannel, isLoggingEnabled, receive, receive, receiveMessage, receiveMessage, registerMetricsCaptor, registerReplyMessageCorrelatorIfNecessary, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, sendTimer, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setErrorOnTimeout, setLoggingEnabled, setManagedName, setManagedType, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrackdoStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic WebFluxInboundEndpoint()
public WebFluxInboundEndpoint(boolean expectReply)
public void setCodecConfigurer(org.springframework.http.codec.ServerCodecConfigurer codecConfigurer)
ServerCodecConfigurer for the request readers and response writers.
By default the ServerCodecConfigurer.create() factory is used.codecConfigurer - the ServerCodecConfigurer to use.public void setRequestedContentTypeResolver(org.springframework.web.reactive.accept.RequestedContentTypeResolver requestedContentTypeResolver)
ServerWebExchange.
A HeaderContentTypeResolver is used by default.requestedContentTypeResolver - the RequestedContentTypeResolver to use.public void setReactiveAdapterRegistry(org.springframework.core.ReactiveAdapterRegistry adapterRegistry)
Publisher to/from.adapterRegistry - the ReactiveAdapterRegistry to use.public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.http.inbound.BaseHttpInboundEndpointpublic reactor.core.publisher.Mono<java.lang.Void> handle(org.springframework.web.server.ServerWebExchange exchange)
handle in interface org.springframework.web.server.WebHandler