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,
com.amazonaws.AmazonWebServiceRequest request,
java.lang.Object result) |
protected void |
doSetHeaderMapper(org.springframework.integration.mapping.HeaderMapper<H> headerMapper) |
protected com.amazonaws.handlers.AsyncHandler<? extends com.amazonaws.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 com.amazonaws.AmazonWebServiceRequest,O> |
obtainAsyncHandler(org.springframework.messaging.Message<?> message,
com.amazonaws.AmazonWebServiceRequest request) |
protected void |
onInit() |
void |
setAsyncHandler(com.amazonaws.handlers.AsyncHandler<? extends com.amazonaws.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, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadersconfigureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitprotected static final long DEFAULT_SEND_TIMEOUT
public void setAsyncHandler(com.amazonaws.handlers.AsyncHandler<? extends com.amazonaws.AmazonWebServiceRequest,?> asyncHandler)
protected com.amazonaws.handlers.AsyncHandler<? extends com.amazonaws.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()
throws java.lang.Exception
onInit in class org.springframework.integration.handler.AbstractMessageProducingHandlerjava.lang.Exceptionprotected void handleMessageInternal(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandlerjava.lang.Exceptionprotected <I extends com.amazonaws.AmazonWebServiceRequest,O> com.amazonaws.handlers.AsyncHandler<I,O> obtainAsyncHandler(org.springframework.messaging.Message<?> message,
com.amazonaws.AmazonWebServiceRequest request)
protected abstract java.util.concurrent.Future<?> handleMessageToAws(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
java.lang.Exceptionprotected abstract void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
com.amazonaws.AmazonWebServiceRequest request,
java.lang.Object result)