public class SqsMessageHandler extends AbstractAwsMessageHandler
AbstractMessageHandler
implementation for the Amazon SQS sendMessage
.AmazonSQSAsync.sendMessageAsync(SendMessageRequest, AsyncHandler)
,
AsyncHandler
DEFAULT_SEND_TIMEOUT
messagingTemplate
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) |
getAsyncHandler, getErrorMessageStrategy, getEvaluationContext, getFailureChannel, getSendTimeoutExpression, handleMessageInternal, isSync, obtainAsyncHandler, setAsyncHandler, setErrorMessageStrategy, setFailureChannel, setFailureChannelName, setSendTimeout, setSendTimeoutExpression, setSendTimeoutExpressionString, setSync
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public 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.lang.Exception
protected java.util.concurrent.Future<?> handleMessageToAws(org.springframework.messaging.Message<?> message)
handleMessageToAws
in class AbstractAwsMessageHandler
protected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder, com.amazonaws.AmazonWebServiceRequest request, java.lang.Object result)
additionalOnSuccessHeaders
in class AbstractAwsMessageHandler