@ManagedResource
@IntegrationManagedResource
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(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
java.lang.String... queues) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
protected void |
doStart() |
protected void |
doStop() |
java.lang.String |
getComponentType() |
boolean |
isRunning(java.lang.String logicalQueueName) |
protected void |
onInit() |
void |
setAutoStartup(boolean autoStartUp) |
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 |
setQueueStopTimeout(long queueStopTimeout) |
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) |
void |
start(java.lang.String logicalQueueName) |
void |
stop(java.lang.String logicalQueueName) |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack
doStop, getPhase, getRole, isAutoStartup, isRunning, setPhase, setRole, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
public SqsMessageDrivenChannelAdapter(com.amazonaws.services.sqs.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 setAutoStartup(boolean autoStartUp)
setAutoStartup
in class org.springframework.integration.endpoint.AbstractEndpoint
public void setDestinationResolver(org.springframework.messaging.core.DestinationResolver<java.lang.String> destinationResolver)
public void setQueueStopTimeout(long queueStopTimeout)
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
@ManagedOperation public void stop(java.lang.String logicalQueueName)
@ManagedOperation public void start(java.lang.String logicalQueueName)
@ManagedOperation public boolean isRunning(java.lang.String logicalQueueName)
public void destroy()
destroy
in interface org.springframework.beans.factory.DisposableBean
destroy
in class org.springframework.integration.endpoint.AbstractEndpoint