org.springframework.integration.http.inbound

Class HttpRequestHandlingEndpointSupport

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.gateway.MessagingGatewaySupport

org.springframework.integration.http.inbound.HttpRequestHandlingEndpointSupport

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, OrderlyShutdownCapable, TrackableComponent, NamedComponent

Direct Known Subclasses:

HttpRequestHandlingController, HttpRequestHandlingMessagingGateway

public abstract class HttpRequestHandlingEndpointSupport
extends MessagingGatewaySupport
implements OrderlyShutdownCapable

Base class for HTTP request handling endpoints.

By default GET and POST requests are accepted via a supplied default instance of RequestMapping. A GET request will generate a payload containing its 'parameterMap' while a POST request will be converted to a Message payload according to the registered HttpMessageConverters. Several are registered by default, but the list can be explicitly set via setMessageConverters(List).

To customize the mapping of request headers to the MessageHeaders, provide a reference to a HeaderMapper<HttpHeaders> implementation to the setHeaderMapper(HeaderMapper) method.

The behavior is "request/reply" by default. Pass false to the constructor to force send-only as opposed to sendAndReceive. Send-only means that as soon as the Message is created and passed to the request channel, a response will be generated. Subclasses determine how that response is generated (e.g. simple status response or rendering a View).

In a request-reply scenario, the reply Message's payload will be extracted prior to generating a response by default. To have the entire serialized Message available for the response, switch the extractReplyPayload value to false.

Since:

2.0

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan, Biju Kunjummen

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
HttpRequestHandlingEndpointSupport()
HttpRequestHandlingEndpointSupport(boolean expectReply)

Method Summary

Methods

Modifier and Type	Method and Description
int	afterShutdown() Called after normal shutdown of schedulers, executors etc, and after the shutdown delay has elapsed, but before any forced shutdown of any remaining active scheduler/executor threads.Can optionally return the number of active messages still in process.
int	beforeShutdown() Called before shutdown begins.
protected StandardEvaluationContext	createEvaluationContext()
protected Message<?>	doHandleRequest(HttpServletRequest servletRequest, HttpServletResponse servletResponse) Handles the HTTP request by generating a Message and sending it to the request channel.
protected void	doStart() Lifecycle
String	getComponentType() Subclasses may implement this method to provide component type information.
protected List<HttpMessageConverter<?>>	getMessageConverters()
RequestMapping	getRequestMapping()
protected boolean	isExpectReply()
protected boolean	isShuttingDown()
protected void	onInit() Locates the MultipartResolver bean based on the default name defined by the DispatcherServlet.MULTIPART_RESOLVER_BEAN_NAME constant if available.
void	setExtractReplyPayload(boolean extractReplyPayload) Specify whether only the reply Message's payload should be passed in the response.
void	setHeaderExpressions(Map<String,Expression> headerExpressions) Specifies a Map of SpEL expressions to evaluate in order to generate the Message headers.
void	setHeaderMapper(HeaderMapper<HttpHeaders> headerMapper) Set the HeaderMapper to use when mapping between HTTP headers and MessageHeaders.
void	setMergeWithDefaultConverters(boolean mergeWithDefaultConverters) Flag which determines if the default converters should be available after custom converters.
void	setMessageConverters(List<HttpMessageConverter<?>> messageConverters) Set the message body converters to use.
void	setMultipartResolver(MultipartResolver multipartResolver) Specify the MultipartResolver to use when checking requests.
void	setPath(String path) Deprecated. since 3.0 in favor of requestMapping
void	setPayloadExpression(Expression payloadExpression) Specifies a SpEL expression to evaluate in order to generate the Message payload.
void	setRequestMapping(RequestMapping requestMapping) Set the RequestMapping which allows you to specify a flexible RESTFul-mapping for this endpoint.
void	setRequestPayloadType(Class<?> requestPayloadType) Specify the type of payload to be generated when the inbound HTTP request content is read by the HttpMessageConverters.
void	setSupportedMethods(HttpMethod... supportedMethods) Deprecated. since 3.0 in favor to requestMapping
protected Object	setupResponseAndConvertReply(ServletServerHttpResponse response, Message<?> replyMessage) Converts the reply message to the appropriate HTTP reply object and sets up the ServletServerHttpResponse.

Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

doStop, receive, send, sendAndReceive, sendAndReceiveMessage, setErrorChannel, setReplyChannel, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestMapper, setRequestTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, 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

HttpRequestHandlingEndpointSupport

public HttpRequestHandlingEndpointSupport()

HttpRequestHandlingEndpointSupport

public HttpRequestHandlingEndpointSupport(boolean expectReply)

Method Detail

isExpectReply

protected boolean isExpectReply()

Returns:

Whether to expect a reply.

setPath

@Deprecated
public void setPath(String path)

Deprecated. since 3.0 in favor of requestMapping

Set the path template for which this endpoint expects requests. May include path variable {keys} to match against.

Parameters:

path - The path.

setPayloadExpression

public void setPayloadExpression(Expression payloadExpression)

Specifies a SpEL expression to evaluate in order to generate the Message payload. The EvaluationContext will be populated with an HttpEntity instance as the root object, and it may contain variables:

• #pathVariables
• #requestParams
• #requestAttributes
• #requestHeaders
• #matrixVariables
• #cookies

Parameters:

payloadExpression - The payload expression.

setHeaderExpressions

public void setHeaderExpressions(Map<String,Expression> headerExpressions)

Specifies a Map of SpEL expressions to evaluate in order to generate the Message headers. The keys in the map will be used as the header names. When evaluating the expression, the EvaluationContext will be populated with an HttpEntity instance as the root object, and it may contain variables:

• #pathVariables
• #requestParams
• #requestAttributes
• #requestHeaders
• #matrixVariables
• #cookies

Parameters:

headerExpressions - The header expressions.

setMessageConverters

public void setMessageConverters(List<HttpMessageConverter<?>> messageConverters)

Set the message body converters to use. These converters are used to convert from and to HTTP requests and responses.

Parameters:

messageConverters - The message converters.

getMessageConverters

protected List<HttpMessageConverter<?>> getMessageConverters()

setMergeWithDefaultConverters

public void setMergeWithDefaultConverters(boolean mergeWithDefaultConverters)

Flag which determines if the default converters should be available after custom converters.

Parameters:

mergeWithDefaultConverters - true to merge, false to replace.

setHeaderMapper

public void setHeaderMapper(HeaderMapper<HttpHeaders> headerMapper)

Set the HeaderMapper to use when mapping between HTTP headers and MessageHeaders.

Parameters:

headerMapper - The header mapper.

setRequestMapping

public void setRequestMapping(RequestMapping requestMapping)

Set the RequestMapping which allows you to specify a flexible RESTFul-mapping for this endpoint.

Parameters:

requestMapping - The request mapping.

getRequestMapping

public final RequestMapping getRequestMapping()

setSupportedMethods

@Deprecated
public void setSupportedMethods(HttpMethod... supportedMethods)

Deprecated. since 3.0 in favor to requestMapping

Specify the supported request methods for this gateway. By default, only GET and POST are supported.

Parameters:

supportedMethods - The supported methods.

setRequestPayloadType

public void setRequestPayloadType(Class<?> requestPayloadType)

Specify the type of payload to be generated when the inbound HTTP request content is read by the HttpMessageConverters. By default this value is null which means at runtime any "text" Content-Type will result in String while all others default to byte[].class.

Parameters:

requestPayloadType - The payload type.

setExtractReplyPayload

public void setExtractReplyPayload(boolean extractReplyPayload)

Specify whether only the reply Message's payload should be passed in the response. If this is set to 'false', the entire Message will be used to generate the response. The default is 'true'.

Parameters:

extractReplyPayload - true to extract the reply payload.

setMultipartResolver

public void setMultipartResolver(MultipartResolver multipartResolver)

Specify the MultipartResolver to use when checking requests. If no resolver is provided, the "multipartResolver" bean in the context will be used as a fallback. If that is not available either, this endpoint will not support multipart requests.

Parameters:

multipartResolver - The multipart resolver.

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 MessagingGatewaySupport

onInit

protected void onInit()
               throws Exception

Locates the MultipartResolver bean based on the default name defined by the DispatcherServlet.MULTIPART_RESOLVER_BEAN_NAME constant if available. Sets up default converters if no converters set, or setMergeWithDefaultConverters(boolean) was called with true after the converters were set.

Overrides:

onInit in class MessagingGatewaySupport

Throws:

Exception - Any exception.

doHandleRequest

protected final Message<?> doHandleRequest(HttpServletRequest servletRequest,
                         HttpServletResponse servletResponse)
                                    throws IOException

Handles the HTTP request by generating a Message and sending it to the request channel. If this gateway's 'expectReply' property is true, it will also generate a response from the reply Message once received.

Parameters:

servletRequest - The servlet request.

servletResponse - The servlet response.

Returns:

The response Message.

Throws:

IOException - Any IOException.

setupResponseAndConvertReply

protected final Object setupResponseAndConvertReply(ServletServerHttpResponse response,
                                  Message<?> replyMessage)

Converts the reply message to the appropriate HTTP reply object and sets up the ServletServerHttpResponse.

Parameters:

response - The ServletServerHttpResponse.

replyMessage - The reply message.

Returns:

The message payload (if extractReplyPayload) otherwise the message.

createEvaluationContext

protected StandardEvaluationContext createEvaluationContext()

doStart

protected void doStart()

Lifecycle

Overrides:

doStart in class MessagingGatewaySupport

isShuttingDown

protected boolean isShuttingDown()

beforeShutdown

public int beforeShutdown()

Description copied from interface: OrderlyShutdownCapable

Called before shutdown begins. Implementations should stop accepting new messages. Can optionally return the number of active messages in process.

Specified by:

beforeShutdown in interface OrderlyShutdownCapable

Returns:

The number of active messages if available.

afterShutdown

public int afterShutdown()

Description copied from interface: OrderlyShutdownCapable

Called after normal shutdown of schedulers, executors etc, and after the shutdown delay has elapsed, but before any forced shutdown of any remaining active scheduler/executor threads.Can optionally return the number of active messages still in process.

Specified by:

afterShutdown in interface OrderlyShutdownCapable

Returns:

The number of active messages if available.