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,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.context.OrderlyShutdownCapable,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationInboundManagement,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.ManageableSmartLifecycle,org.springframework.integration.support.management.TrackableComponent,org.springframework.web.server.WebHandler
public class WebFluxInboundEndpoint
extends org.springframework.integration.http.inbound.BaseHttpInboundEndpoint
implements org.springframework.web.server.WebHandler
A
MessagingGatewaySupport
implementation for Spring WebFlux HTTP requests execution.- Since:
- 5.0
- See Also:
HandlerResultHandlerSupport,EnableWebFlux
-
Nested Class Summary
-
Field Summary
Fields inherited from class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint
activeCount, JAXB_PRESENT, NON_READABLE_BODY_HTTP_METHODS, ROME_TOOLS_PRESENTFields inherited from class org.springframework.integration.gateway.MessagingGatewaySupport
messagingTemplateFields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLockFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger -
Constructor Summary
Constructors Constructor Description WebFluxInboundEndpoint()WebFluxInboundEndpoint(boolean expectReply) -
Method Summary
Modifier and Type Method Description java.lang.StringgetComponentType()reactor.core.publisher.Mono<java.lang.Void>handle(org.springframework.web.server.ServerWebExchange exchange)voidsetCodecConfigurer(org.springframework.http.codec.ServerCodecConfigurer codecConfigurer)AServerCodecConfigurerfor the request readers and response writers.voidsetReactiveAdapterRegistry(org.springframework.core.ReactiveAdapterRegistry adapterRegistry)A registry of adapters to adapt a Reactive StreamsPublisherto/from.voidsetRequestedContentTypeResolver(org.springframework.web.reactive.accept.RequestedContentTypeResolver requestedContentTypeResolver)A strategy to resolve the requested media types for aServerWebExchange.Methods inherited from class org.springframework.integration.http.inbound.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, validateMethods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport
buildErrorMessage, 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, setShouldTrackMethods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
WebFluxInboundEndpoint
public WebFluxInboundEndpoint() -
WebFluxInboundEndpoint
public WebFluxInboundEndpoint(boolean expectReply)
-
-
Method Details
-
setCodecConfigurer
public void setCodecConfigurer(org.springframework.http.codec.ServerCodecConfigurer codecConfigurer)AServerCodecConfigurerfor the request readers and response writers. By default theServerCodecConfigurer.create()factory is used.- Parameters:
codecConfigurer- theServerCodecConfigurerto use.
-
setRequestedContentTypeResolver
public void setRequestedContentTypeResolver(org.springframework.web.reactive.accept.RequestedContentTypeResolver requestedContentTypeResolver)A strategy to resolve the requested media types for aServerWebExchange. AHeaderContentTypeResolveris used by default.- Parameters:
requestedContentTypeResolver- theRequestedContentTypeResolverto use.
-
setReactiveAdapterRegistry
public void setReactiveAdapterRegistry(org.springframework.core.ReactiveAdapterRegistry adapterRegistry)A registry of adapters to adapt a Reactive StreamsPublisherto/from.- Parameters:
adapterRegistry- theReactiveAdapterRegistryto use.
-
getComponentType
public java.lang.String getComponentType()- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.http.inbound.BaseHttpInboundEndpoint
-
handle
public reactor.core.publisher.Mono<java.lang.Void> handle(org.springframework.web.server.ServerWebExchange exchange)- Specified by:
handlein interfaceorg.springframework.web.server.WebHandler
-