public class SqsMessageHandler extends AbstractAwsMessageHandler<java.util.Map<java.lang.String,com.amazonaws.services.sqs.model.MessageAttributeValue>>
AbstractMessageHandler implementation for the Amazon SQS sendMessage.AmazonSQSAsync.sendMessageAsync(SendMessageRequest, AsyncHandler),
AsyncHandlerDEFAULT_SEND_TIMEOUTmessagingTemplateEXPRESSION_PARSER, logger| Constructor and Description |
|---|
SqsMessageHandler(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs) |
SqsMessageHandler(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
org.springframework.cloud.aws.core.env.ResourceIdResolver resourceIdResolver) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
com.amazonaws.AmazonWebServiceRequest request,
java.lang.Object result) |
protected java.util.concurrent.Future<?> |
handleMessageToAws(org.springframework.messaging.Message<?> message) |
protected void |
onInit() |
void |
setDelay(int delaySeconds) |
void |
setDelayExpression(org.springframework.expression.Expression delayExpression) |
void |
setDelayExpressionString(java.lang.String delayExpression) |
void |
setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter) |
void |
setMessageDeduplicationId(java.lang.String messageDeduplicationId) |
void |
setMessageDeduplicationIdExpression(org.springframework.expression.Expression messageDeduplicationIdExpression) |
void |
setMessageDeduplicationIdExpressionString(java.lang.String messageDeduplicationIdExpression) |
void |
setMessageGroupId(java.lang.String messageGroupId) |
void |
setMessageGroupIdExpression(org.springframework.expression.Expression messageGroupIdExpression) |
void |
setMessageGroupIdExpressionString(java.lang.String groupIdExpression) |
void |
setQueue(java.lang.String queue) |
void |
setQueueExpression(org.springframework.expression.Expression queueExpression) |
void |
setQueueExpressionString(java.lang.String queueExpression) |
doSetHeaderMapper, getAsyncHandler, getErrorMessageStrategy, getEvaluationContext, getFailureChannel, getHeaderMapper, getSendTimeoutExpression, handleMessageInternal, isSync, obtainAsyncHandler, setAsyncHandler, setErrorMessageStrategy, setFailureChannel, setFailureChannelName, setHeaderMapper, setSendTimeout, setSendTimeoutExpression, setSendTimeoutExpressionString, setSyncaddNotPropagatedHeaders, 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, waitpublic SqsMessageHandler(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs)
public SqsMessageHandler(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
org.springframework.cloud.aws.core.env.ResourceIdResolver resourceIdResolver)
public void setQueue(java.lang.String queue)
public void setQueueExpressionString(java.lang.String queueExpression)
public void setQueueExpression(org.springframework.expression.Expression queueExpression)
public void setDelay(int delaySeconds)
public void setDelayExpressionString(java.lang.String delayExpression)
public void setDelayExpression(org.springframework.expression.Expression delayExpression)
public void setMessageGroupId(java.lang.String messageGroupId)
public void setMessageGroupIdExpressionString(java.lang.String groupIdExpression)
public void setMessageGroupIdExpression(org.springframework.expression.Expression messageGroupIdExpression)
public void setMessageDeduplicationId(java.lang.String messageDeduplicationId)
public void setMessageDeduplicationIdExpressionString(java.lang.String messageDeduplicationIdExpression)
public void setMessageDeduplicationIdExpression(org.springframework.expression.Expression messageDeduplicationIdExpression)
public void setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter)
protected void onInit()
throws java.lang.Exception
onInit in class AbstractAwsMessageHandler<java.util.Map<java.lang.String,com.amazonaws.services.sqs.model.MessageAttributeValue>>java.lang.Exceptionprotected java.util.concurrent.Future<?> handleMessageToAws(org.springframework.messaging.Message<?> message)
handleMessageToAws in class AbstractAwsMessageHandler<java.util.Map<java.lang.String,com.amazonaws.services.sqs.model.MessageAttributeValue>>protected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
com.amazonaws.AmazonWebServiceRequest request,
java.lang.Object result)
additionalOnSuccessHeaders in class AbstractAwsMessageHandler<java.util.Map<java.lang.String,com.amazonaws.services.sqs.model.MessageAttributeValue>>