org.springframework.integration.http.inbound

Class BaseHttpInboundEndpoint

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.gateway.MessagingGatewaySupport

org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

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, ExpressionCapable, OrderlyShutdownCapable, NamedComponent, IntegrationManagement, MessageSourceMetrics, TrackableComponent

Direct Known Subclasses:

HttpRequestHandlingEndpointSupport, WebFluxInboundEndpoint

public class BaseHttpInboundEndpoint
extends MessagingGatewaySupport
implements OrderlyShutdownCapable

The MessagingGatewaySupport extension for HTTP Inbound endpoints with basic properties.

Since:

5.0

Author:

Artem Bilan, Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicInteger	activeCount
protected boolean	expectReply
protected static boolean	jaxb2Present
protected static java.util.List<org.springframework.http.HttpMethod>	nonReadableBodyHttpMethods
protected static boolean	romeToolsPresent

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

messagingTemplate

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

lifecycleCondition, lifecycleLock

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

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor and Description
BaseHttpInboundEndpoint(boolean expectReply)

Method Summary

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 org.springframework.expression.spel.support.StandardEvaluationContext	createEvaluationContext()
protected org.springframework.http.HttpStatus	evaluateHttpStatus()
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
CrossOrigin	getCrossOrigin()
protected boolean	getExtractReplyPayload()
protected java.util.Map<java.lang.String,org.springframework.expression.Expression>	getHeaderExpressions()
protected HeaderMapper<org.springframework.http.HttpHeaders>	getHeaderMapper()
protected org.springframework.expression.Expression	getPayloadExpression()
RequestMapping	getRequestMapping()
protected org.springframework.core.ResolvableType	getRequestPayloadType()
protected org.springframework.expression.Expression	getStatusCodeExpression()
protected boolean	isExpectReply()
protected boolean	isReadable(org.springframework.http.HttpRequest request) Checks if the request has a readable body (not a GET, HEAD, or OPTIONS request).
protected void	onInit() Subclasses may implement this for initialization logic.
protected org.springframework.http.HttpStatus	resolveHttpStatusFromHeaders(org.springframework.messaging.MessageHeaders headers)
void	setCrossOrigin(CrossOrigin crossOrigin) Set the CrossOrigin to permit cross origin requests for this endpoint.
void	setExtractReplyPayload(boolean extractReplyPayload) Specify whether only the reply Message's payload should be passed in the response.
void	setHeaderExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> headerExpressions) Specifies a Map of SpEL expressions to evaluate in order to generate the Message headers.
void	setHeaderMapper(HeaderMapper<org.springframework.http.HttpHeaders> headerMapper) Set the HeaderMapper to use when mapping between HTTP headers and MessageHeaders.
void	setPayloadExpression(org.springframework.expression.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(org.springframework.core.ResolvableType requestPayloadType) Specify the type of payload to be generated when the inbound HTTP request content is read by the converters/encoders.
void	setRequestPayloadTypeClass(java.lang.Class<?> requestPayloadType) Specify the type of payload to be generated when the inbound HTTP request content is read by the converters/encoders.
void	setStatusCodeExpression(org.springframework.expression.Expression statusCodeExpression) Specify the Expression to resolve a status code for Response to override the default '200 OK' or '500 Internal Server Error' for a timeout.
void	setStatusCodeExpressionString(java.lang.String statusCodeExpression) Specify the Expression to resolve a status code for Response to override the default '200 OK' or '500 Internal Server Error' for a timeout.

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

buildErrorMessage, 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, setShouldTrack

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

destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stop

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

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

Methods inherited from interface org.springframework.integration.support.management.MessageSourceMetrics

setCounter

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

registerMetricsCaptor

Field Detail

jaxb2Present

protected static final boolean jaxb2Present

romeToolsPresent

protected static final boolean romeToolsPresent

nonReadableBodyHttpMethods

protected static final java.util.List<org.springframework.http.HttpMethod> nonReadableBodyHttpMethods

expectReply

protected final boolean expectReply

activeCount

protected final java.util.concurrent.atomic.AtomicInteger activeCount

Constructor Detail

BaseHttpInboundEndpoint

public BaseHttpInboundEndpoint(boolean expectReply)

Method Detail

setPayloadExpression

public void setPayloadExpression(org.springframework.expression.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(java.util.Map<java.lang.String,org.springframework.expression.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.

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()

setCrossOrigin

public void setCrossOrigin(CrossOrigin crossOrigin)

Set the CrossOrigin to permit cross origin requests for this endpoint.

Parameters:

crossOrigin - the CrossOrigin config.

Since:

4.2

getCrossOrigin

public CrossOrigin getCrossOrigin()

getPayloadExpression

protected org.springframework.expression.Expression getPayloadExpression()

getHeaderExpressions

protected java.util.Map<java.lang.String,org.springframework.expression.Expression> getHeaderExpressions()

isExpectReply

protected boolean isExpectReply()

Returns:

Whether to expect a reply.

setHeaderMapper

public void setHeaderMapper(HeaderMapper<org.springframework.http.HttpHeaders> headerMapper)

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

Parameters:

headerMapper - The header mapper.

getHeaderMapper

protected HeaderMapper<org.springframework.http.HttpHeaders> getHeaderMapper()

setRequestPayloadTypeClass

public void setRequestPayloadTypeClass(java.lang.Class<?> requestPayloadType)

Specify the type of payload to be generated when the inbound HTTP request content is read by the converters/encoders. 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.

setRequestPayloadType

public void setRequestPayloadType(org.springframework.core.ResolvableType requestPayloadType)

Specify the type of payload to be generated when the inbound HTTP request content is read by the converters/encoders. 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.

getRequestPayloadType

protected org.springframework.core.ResolvableType getRequestPayloadType()

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.

getExtractReplyPayload

protected boolean getExtractReplyPayload()

setStatusCodeExpressionString

public void setStatusCodeExpressionString(java.lang.String statusCodeExpression)

Specify the Expression to resolve a status code for Response to override the default '200 OK' or '500 Internal Server Error' for a timeout.

Parameters:

statusCodeExpression - The status code Expression.

Since:

5.0

See Also:

setStatusCodeExpression(Expression)

setStatusCodeExpression

public void setStatusCodeExpression(org.springframework.expression.Expression statusCodeExpression)

Specify the Expression to resolve a status code for Response to override the default '200 OK' or '500 Internal Server Error' for a timeout.

The statusCodeExpression is applied only for the one-way <http:inbound-channel-adapter/> or when no reply (timeout) is received for a gateway. The <http:inbound-gateway/> (or whenever expectReply is true) resolves an HttpStatus from the HttpHeaders.STATUS_CODE reply Message header.

Parameters:

statusCodeExpression - The status code Expression.

Since:

4.1

See Also:

MessagingGatewaySupport.setReplyTimeout(long), HttpRequestHandlingEndpointSupport.HttpRequestHandlingEndpointSupport(boolean)

getStatusCodeExpression

protected org.springframework.expression.Expression getStatusCodeExpression()

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class MessagingGatewaySupport

Throws:

java.lang.Exception - Any exception.

evaluateHttpStatus

protected org.springframework.http.HttpStatus evaluateHttpStatus()

resolveHttpStatusFromHeaders

protected org.springframework.http.HttpStatus resolveHttpStatusFromHeaders(org.springframework.messaging.MessageHeaders headers)

createEvaluationContext

protected org.springframework.expression.spel.support.StandardEvaluationContext createEvaluationContext()

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.

getComponentType

public java.lang.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

isReadable

protected boolean isReadable(org.springframework.http.HttpRequest request)

Checks if the request has a readable body (not a GET, HEAD, or OPTIONS request).

Parameters:

request - the HTTP request to check the method

Returns:

true or false if HTTP request can contain the body