public class SqsMessageHandler
extends org.springframework.integration.handler.AbstractMessageHandler
AbstractMessageHandler
implementation for the Amazon SQS sendMessage
.QueueMessagingTemplate
,
QueueMessageChannel
Constructor and Description |
---|
SqsMessageHandler(AmazonSQS amazonSqs) |
SqsMessageHandler(AmazonSQS 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, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public SqsMessageHandler(AmazonSQS amazonSqs)
public SqsMessageHandler(AmazonSQS 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.AbstractMessageHandler
java.lang.Exception
protected void handleMessageInternal(org.springframework.messaging.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class org.springframework.integration.handler.AbstractMessageHandler
java.lang.Exception