Package org.springframework.integration.webflux.inbound

Class WebFluxIntegrationRequestMappingHandlerMapping

java.lang.Object

org.springframework.context.support.ApplicationObjectSupport

org.springframework.web.reactive.handler.AbstractHandlerMapping

org.springframework.web.reactive.result.method.AbstractHandlerMethodMapping<RequestMappingInfo>

org.springframework.web.reactive.result.method.RequestMappingInfoHandlerMapping

org.springframework.web.reactive.result.method.annotation.RequestMappingHandlerMapping

org.springframework.integration.webflux.inbound.WebFluxIntegrationRequestMappingHandlerMapping

All Implemented Interfaces:

EventListener, Aware, BeanNameAware, BeanPostProcessor, DestructionAwareBeanPostProcessor, InitializingBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, EmbeddedValueResolverAware, Ordered, HandlerMapping

public class WebFluxIntegrationRequestMappingHandlerMapping
extends RequestMappingHandlerMapping
implements ApplicationListener<ContextRefreshedEvent>, DestructionAwareBeanPostProcessor

The HandlerMapping implementation that detects and registers RequestMappingInfos for HttpRequestHandlingEndpointSupport from a Spring Integration HTTP configuration of <inbound-channel-adapter/> and <inbound-gateway/> elements.

This class is automatically configured as a bean in the application context during the parsing phase of the <inbound-gateway/> elements, if there is none registered, yet. However it can be configured as a regular bean with appropriate configuration for RequestMappingHandlerMapping. It is recommended to have only one similar bean in the application context using the 'id' WebFluxContextUtils.HANDLER_MAPPING_BEAN_NAME.

In most cases, Spring MVC offers to configure Request Mapping via org.springframework.stereotype.Controller and RequestMapping. That's why Spring MVC's Handler Mapping infrastructure relies on HandlerMethod, as different methods at the same org.springframework.stereotype.Controller user-class may have their own RequestMapping. On the other side, all Spring Integration HTTP Inbound Endpoints are configured on the basis of the same HttpRequestHandlingEndpointSupport class and there is no single RequestMappingInfo configuration without HandlerMethod in Spring MVC. Accordingly WebFluxIntegrationRequestMappingHandlerMapping is a HandlerMapping compromise implementation between method-level annotations and component-level (e.g. Spring Integration XML) configurations.

Starting with version 5.1, this class implements DestructionAwareBeanPostProcessor to register HTTP endpoints at runtime for dynamically declared beans, e.g. via IntegrationFlowContext, and unregister them during the WebFluxInboundEndpoint destruction.

Since:

5.0

Author:

Artem Bilan, Gary Russell

See Also:

• RequestMapping
• RequestMappingHandlerMapping

Field Summary

Fields inherited from class org.springframework.web.reactive.handler.AbstractHandlerMapping

mappingsLogger

Fields inherited from class org.springframework.context.support.ApplicationObjectSupport

logger

Fields inherited from interface org.springframework.web.reactive.HandlerMapping

BEST_MATCHING_HANDLER_ATTRIBUTE, BEST_MATCHING_PATTERN_ATTRIBUTE, MATRIX_VARIABLES_ATTRIBUTE, PATH_WITHIN_HANDLER_MAPPING_ATTRIBUTE, PRODUCIBLE_MEDIA_TYPES_ATTRIBUTE, URI_TEMPLATE_VARIABLES_ATTRIBUTE

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
WebFluxIntegrationRequestMappingHandlerMapping()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected void	detectHandlerMethods(Object handler)
protected CorsConfiguration	initCorsConfiguration(Object handler, Method method, RequestMappingInfo mappingInfo)
protected boolean	isHandler(Class<?> beanType)
void	onApplicationEvent(ContextRefreshedEvent event)	HttpRequestHandlingEndpointSupports may depend on auto-created requestChannels, so MVC Handlers detection should be postponed as late as possible.
void	postProcessBeforeDestruction(Object bean, String beanName)
Object	postProcessBeforeInitialization(Object bean, String beanName)
boolean	requiresDestruction(Object bean)

Methods inherited from class org.springframework.web.reactive.result.method.annotation.RequestMappingHandlerMapping

createRequestMappingInfo, getContentTypeResolver, getCustomMethodCondition, getCustomTypeCondition, getMappingForMethod, getPathPrefixes, registerHandlerMethod, registerMapping, resolveEmbeddedValuesInPatterns, setContentTypeResolver, setEmbeddedValueResolver, setPathPrefixes

Methods inherited from class org.springframework.web.reactive.result.method.RequestMappingInfoHandlerMapping

getDirectPaths, getHandlerInternal, getMappingComparator, getMatchingMapping, handleMatch, handleNoMatch

Methods inherited from class org.springframework.web.reactive.result.method.AbstractHandlerMethodMapping

createHandlerMethod, getCorsConfiguration, getHandlerMethods, handlerMethodsInitialized, hasCorsConfigurationSource, initHandlerMethods, lookupHandlerMethod, unregisterMapping

Methods inherited from class org.springframework.web.reactive.handler.AbstractHandlerMapping

formatMappingName, getCorsProcessor, getHandler, getOrder, getPathPatternParser, setBeanName, setCorsConfigurations, setCorsConfigurationSource, setCorsProcessor, setOrder, setUseCaseSensitiveMatch, setUseTrailingSlashMatch

Methods inherited from class org.springframework.context.support.ApplicationObjectSupport

getApplicationContext, getMessageSourceAccessor, initApplicationContext, initApplicationContext, isContextRequired, obtainApplicationContext, requiredContextClass, setApplicationContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.config.BeanPostProcessor

postProcessAfterInitialization

Constructor Details

WebFluxIntegrationRequestMappingHandlerMapping

public WebFluxIntegrationRequestMappingHandlerMapping()

Method Details

postProcessBeforeInitialization

public Object postProcessBeforeInitialization(Object bean,
 String beanName)
                                       throws BeansException

Specified by:

postProcessBeforeInitialization in interface BeanPostProcessor

Throws:

BeansException

postProcessBeforeDestruction

public void postProcessBeforeDestruction(Object bean,
 String beanName)
                                  throws BeansException

Specified by:

postProcessBeforeDestruction in interface DestructionAwareBeanPostProcessor

Throws:

BeansException

requiresDestruction

public boolean requiresDestruction(Object bean)

Specified by:

requiresDestruction in interface DestructionAwareBeanPostProcessor

isHandler

protected boolean isHandler(Class<?> beanType)

Overrides:

isHandler in class RequestMappingHandlerMapping

detectHandlerMethods

protected void detectHandlerMethods(Object handler)

Overrides:

detectHandlerMethods in class AbstractHandlerMethodMapping<RequestMappingInfo>

initCorsConfiguration

protected CorsConfiguration initCorsConfiguration(Object handler,
 Method method,
 RequestMappingInfo mappingInfo)

Overrides:

initCorsConfiguration in class RequestMappingHandlerMapping

onApplicationEvent

public void onApplicationEvent(ContextRefreshedEvent event)

HttpRequestHandlingEndpointSupports may depend on auto-created requestChannels, so MVC Handlers detection should be postponed as late as possible.

Specified by:

onApplicationEvent in interface ApplicationListener<ContextRefreshedEvent>

See Also:

• RequestMappingHandlerMapping.afterPropertiesSet()

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

Overrides:

afterPropertiesSet in class RequestMappingHandlerMapping