public class SqsMessageDrivenChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.beans.factory.DisposableBean
MessageProducerSupport
implementation for the Amazon SQS receiveMessage
.
Works in 'listener' manner and delegates hard to the SimpleMessageListenerContainer
.SimpleMessageListenerContainerFactory
,
SimpleMessageListenerContainer
,
QueueMessageHandler
Constructor and Description |
---|
SqsMessageDrivenChannelAdapter(AmazonSQSAsync amazonSqs,
java.lang.String... queues) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
protected void |
doStart() |
protected void |
doStop() |
java.lang.String |
getComponentType() |
protected void |
onInit() |
void |
setDestinationResolver(org.springframework.messaging.core.DestinationResolver<java.lang.String> destinationResolver) |
void |
setMaxNumberOfMessages(java.lang.Integer maxNumberOfMessages) |
void |
setMessageDeletionPolicy(org.springframework.cloud.aws.messaging.listener.SqsMessageDeletionPolicy messageDeletionPolicy) |
void |
setResourceIdResolver(org.springframework.cloud.aws.core.env.ResourceIdResolver resourceIdResolver) |
void |
setTaskExecutor(org.springframework.core.task.AsyncTaskExecutor taskExecutor) |
void |
setVisibilityTimeout(java.lang.Integer visibilityTimeout) |
void |
setWaitTimeOut(java.lang.Integer waitTimeOut) |
getMessagingTemplate, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack
doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, toString
public SqsMessageDrivenChannelAdapter(AmazonSQSAsync amazonSqs, java.lang.String... queues)
public void setTaskExecutor(org.springframework.core.task.AsyncTaskExecutor taskExecutor)
public void setMaxNumberOfMessages(java.lang.Integer maxNumberOfMessages)
public void setVisibilityTimeout(java.lang.Integer visibilityTimeout)
public void setWaitTimeOut(java.lang.Integer waitTimeOut)
public void setResourceIdResolver(org.springframework.cloud.aws.core.env.ResourceIdResolver resourceIdResolver)
public void setDestinationResolver(org.springframework.messaging.core.DestinationResolver<java.lang.String> destinationResolver)
public void setMessageDeletionPolicy(org.springframework.cloud.aws.messaging.listener.SqsMessageDeletionPolicy messageDeletionPolicy)
protected void onInit()
onInit
in class org.springframework.integration.endpoint.MessageProducerSupport
public java.lang.String getComponentType()
getComponentType
in interface org.springframework.integration.support.context.NamedComponent
getComponentType
in class org.springframework.integration.context.IntegrationObjectSupport
protected void doStart()
doStart
in class org.springframework.integration.endpoint.MessageProducerSupport
protected void doStop()
doStop
in class org.springframework.integration.endpoint.MessageProducerSupport
public void destroy() throws java.lang.Exception
destroy
in interface org.springframework.beans.factory.DisposableBean
java.lang.Exception