public class SqsMessageHandler
extends org.springframework.integration.handler.AbstractMessageHandler
AbstractMessageHandler implementation for the Amazon SQS sendMessage.QueueMessagingTemplate,
QueueMessageChannel| Constructor and Description |
|---|
SqsMessageHandler(AmazonSQSAsync amazonSqs) |
SqsMessageHandler(AmazonSQSAsync amazonSqs,
org.springframework.cloud.aws.core.env.ResourceIdResolver resourceIdResolver) |
SqsMessageHandler(org.springframework.cloud.aws.messaging.core.QueueMessagingTemplate template) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected void |
onInit() |
void |
setQueue(java.lang.String queue) |
void |
setQueueExpression(org.springframework.expression.Expression queueExpression) |
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, 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, toStringpublic SqsMessageHandler(AmazonSQSAsync amazonSqs)
public SqsMessageHandler(AmazonSQSAsync amazonSqs, org.springframework.cloud.aws.core.env.ResourceIdResolver resourceIdResolver)
public SqsMessageHandler(org.springframework.cloud.aws.messaging.core.QueueMessagingTemplate template)
public void setQueue(java.lang.String queue)
public void setQueueExpression(org.springframework.expression.Expression queueExpression)
protected void onInit()
throws java.lang.Exception
onInit in class org.springframework.integration.handler.AbstractMessageHandlerjava.lang.Exceptionprotected void handleMessageInternal(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandlerjava.lang.Exception