H - the headers container type.public abstract class AbstractAwsMessageHandler<H>
extends org.springframework.integration.handler.AbstractMessageProducingHandler
AbstractMessageProducingHandler for AWS services. Utilizes common
logic (AsyncHandler, ErrorMessageStrategy, failureChannel etc.)
and message pre- and post-processing,| Modifier and Type | Field and Description |
|---|---|
protected static long |
DEFAULT_SEND_TIMEOUT |
messagingTemplateEXPRESSION_PARSER, logger| Constructor and Description |
|---|
AbstractAwsMessageHandler() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
AmazonWebServiceRequest request,
java.lang.Object result) |
protected void |
doSetHeaderMapper(org.springframework.integration.mapping.HeaderMapper<H> headerMapper) |
protected AsyncHandler<? extends AmazonWebServiceRequest,?> |
getAsyncHandler() |
protected org.springframework.integration.support.ErrorMessageStrategy |
getErrorMessageStrategy() |
protected org.springframework.expression.EvaluationContext |
getEvaluationContext() |
protected org.springframework.messaging.MessageChannel |
getFailureChannel() |
protected org.springframework.integration.mapping.HeaderMapper<H> |
getHeaderMapper() |
protected org.springframework.expression.Expression |
getSendTimeoutExpression() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected abstract java.util.concurrent.Future<?> |
handleMessageToAws(org.springframework.messaging.Message<?> message) |
protected boolean |
isSync() |
protected <I extends AmazonWebServiceRequest,O> |
obtainAsyncHandler(org.springframework.messaging.Message<?> message,
AmazonWebServiceRequest request) |
protected void |
onInit() |
void |
setAsyncHandler(AsyncHandler<? extends AmazonWebServiceRequest,?> asyncHandler) |
void |
setErrorMessageStrategy(org.springframework.integration.support.ErrorMessageStrategy errorMessageStrategy) |
void |
setFailureChannel(org.springframework.messaging.MessageChannel failureChannel)
Set the failure channel.
|
void |
setFailureChannelName(java.lang.String failureChannelName)
Set the failure channel name.
|
void |
setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<H> headerMapper)
Specify a
HeaderMapper to map outbound headers. |
void |
setSendTimeout(long sendTimeout) |
void |
setSendTimeoutExpression(org.springframework.expression.Expression sendTimeoutExpression) |
void |
setSendTimeoutExpressionString(java.lang.String sendTimeoutExpression) |
void |
setSync(boolean sync) |
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadersconfigureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabledafterPropertiesSet, 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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waiterrorCount, handleCountprotected static final long DEFAULT_SEND_TIMEOUT
public void setAsyncHandler(AsyncHandler<? extends AmazonWebServiceRequest,?> asyncHandler)
protected AsyncHandler<? extends AmazonWebServiceRequest,?> getAsyncHandler()
public void setSync(boolean sync)
protected boolean isSync()
public void setSendTimeout(long sendTimeout)
setSendTimeout in class org.springframework.integration.handler.AbstractMessageProducingHandlerpublic void setSendTimeoutExpressionString(java.lang.String sendTimeoutExpression)
public void setSendTimeoutExpression(org.springframework.expression.Expression sendTimeoutExpression)
protected org.springframework.expression.Expression getSendTimeoutExpression()
public void setFailureChannel(org.springframework.messaging.MessageChannel failureChannel)
ErrorMessage will be
sent to this channel with a payload of a AwsRequestFailureException with
the failed message and cause.failureChannel - the failure channel.public void setFailureChannelName(java.lang.String failureChannelName)
ErrorMessage will
be sent to this channel name with a payload of a AwsRequestFailureException
with the failed message and cause.failureChannelName - the failure channel name.protected org.springframework.messaging.MessageChannel getFailureChannel()
public void setErrorMessageStrategy(org.springframework.integration.support.ErrorMessageStrategy errorMessageStrategy)
protected org.springframework.integration.support.ErrorMessageStrategy getErrorMessageStrategy()
public void setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<H> headerMapper)
HeaderMapper to map outbound headers.headerMapper - the HeaderMapper to map outbound headers.protected final void doSetHeaderMapper(org.springframework.integration.mapping.HeaderMapper<H> headerMapper)
protected org.springframework.integration.mapping.HeaderMapper<H> getHeaderMapper()
protected org.springframework.expression.EvaluationContext getEvaluationContext()
protected void onInit()
onInit in class org.springframework.integration.handler.AbstractMessageProducingHandlerprotected void handleMessageInternal(org.springframework.messaging.Message<?> message)
handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandlerprotected <I extends AmazonWebServiceRequest,O> AsyncHandler<I,O> obtainAsyncHandler(org.springframework.messaging.Message<?> message, AmazonWebServiceRequest request)
protected abstract java.util.concurrent.Future<?> handleMessageToAws(org.springframework.messaging.Message<?> message)
protected abstract void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
AmazonWebServiceRequest request,
java.lang.Object result)