Class SqsMessageDrivenChannelAdapter
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.beans.factory.SmartInitializingSingleton,org.springframework.context.ApplicationContextAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.core.MessageProducer,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.ManageableSmartLifecycle,org.springframework.integration.support.management.TrackableComponent
@ManagedResource
@IntegrationManagedResource
public class SqsMessageDrivenChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.beans.factory.DisposableBean
The
MessageProducerSupport implementation for the Amazon SQS
receiveMessage. Works in 'listener' manner and delegates hard to the
SimpleMessageListenerContainer.- Author:
- Artem Bilan, Patrick Fitzsimons
- See Also:
-
SimpleMessageListenerContainerFactorySimpleMessageListenerContainerQueueMessageHandler
-
Field Summary
Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLockFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoiddestroy()protected voiddoStart()protected voiddoStop()String[]booleanprotected voidonInit()voidsetAutoStartup(boolean autoStartUp) voidsetDestinationResolver(org.springframework.messaging.core.DestinationResolver<String> destinationResolver) voidsetFailOnMissingQueue(boolean failOnMissingQueue) voidsetMaxNumberOfMessages(Integer maxNumberOfMessages) voidsetMessageDeletionPolicy(io.awspring.cloud.messaging.listener.SqsMessageDeletionPolicy messageDeletionPolicy) voidsetQueueStopTimeout(long queueStopTimeout) voidsetResourceIdResolver(io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver) voidsetTaskExecutor(org.springframework.core.task.AsyncTaskExecutor taskExecutor) voidsetVisibilityTimeout(Integer visibilityTimeout) voidsetWaitTimeOut(Integer waitTimeOut) voidvoidMethods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherMethods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setPhase, setRole, start, stop, stopMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
SqsMessageDrivenChannelAdapter
-
-
Method Details
-
setTaskExecutor
public void setTaskExecutor(org.springframework.core.task.AsyncTaskExecutor taskExecutor) -
setMaxNumberOfMessages
-
setVisibilityTimeout
-
setWaitTimeOut
-
setResourceIdResolver
public void setResourceIdResolver(io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver) -
setAutoStartup
public void setAutoStartup(boolean autoStartUp) - Overrides:
setAutoStartupin classorg.springframework.integration.endpoint.AbstractEndpoint
-
setDestinationResolver
public void setDestinationResolver(org.springframework.messaging.core.DestinationResolver<String> destinationResolver) -
setFailOnMissingQueue
public void setFailOnMissingQueue(boolean failOnMissingQueue) -
setQueueStopTimeout
public void setQueueStopTimeout(long queueStopTimeout) -
setMessageDeletionPolicy
public void setMessageDeletionPolicy(io.awspring.cloud.messaging.listener.SqsMessageDeletionPolicy messageDeletionPolicy) -
onInit
protected void onInit()- Overrides:
onInitin classorg.springframework.integration.endpoint.MessageProducerSupport
-
getComponentType
- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.context.IntegrationObjectSupport
-
doStart
protected void doStart()- Overrides:
doStartin classorg.springframework.integration.endpoint.MessageProducerSupport
-
doStop
protected void doStop()- Overrides:
doStopin classorg.springframework.integration.endpoint.MessageProducerSupport
-
stop
-
start
-
isRunning
-
getQueues
-
destroy
public void destroy()- Specified by:
destroyin interfaceorg.springframework.beans.factory.DisposableBean- Overrides:
destroyin classorg.springframework.integration.endpoint.AbstractEndpoint
-