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, expectReply, jaxb2Present, nonReadableBodyHttpMethods, romeToolsPresentmessagingTemplatelifecycleCondition, 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) |
protected void |
onInit() |
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, getPayloadExpression, getRequestMapping, getRequestPayloadType, getStatusCodeExpression, isExpectReply, isReadable, resolveHttpStatusFromHeaders, setCrossOrigin, setExtractReplyPayload, setHeaderExpressions, setHeaderMapper, setPayloadExpression, setRequestMapping, setRequestPayloadType, setRequestPayloadTypeClass, setStatusCodeExpression, setStatusCodeExpressionStringbuildErrorMessage, 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, setShouldTrackdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic 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.BaseHttpInboundEndpointprotected void onInit()
throws java.lang.Exception
onInit in class org.springframework.integration.http.inbound.BaseHttpInboundEndpointjava.lang.Exceptionpublic reactor.core.publisher.Mono<java.lang.Void> handle(org.springframework.web.server.ServerWebExchange exchange)
handle in interface org.springframework.web.server.WebHandler