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:
  • SimpleMessageListenerContainerFactory
  • SimpleMessageListenerContainer
  • QueueMessageHandler
  • Field Summary

    Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

    lifecycleCondition, lifecycleLock

    Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

    EXPRESSION_PARSER, logger

    Fields inherited from interface org.springframework.context.SmartLifecycle

    DEFAULT_PHASE
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    void
     
    protected void
     
    protected void
     
     
     
    boolean
    isRunning(String logicalQueueName)
     
    protected void
     
    void
    setAutoStartup(boolean autoStartUp)
     
    void
    setDestinationResolver(org.springframework.messaging.core.DestinationResolver<String> destinationResolver)
     
    void
    setFailOnMissingQueue(boolean failOnMissingQueue)
     
    void
    setMaxNumberOfMessages(Integer maxNumberOfMessages)
     
    void
    setMessageDeletionPolicy(io.awspring.cloud.messaging.listener.SqsMessageDeletionPolicy messageDeletionPolicy)
     
    void
    setQueueStopTimeout(long queueStopTimeout)
     
    void
    setResourceIdResolver(io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver)
     
    void
    setTaskExecutor(org.springframework.core.task.AsyncTaskExecutor taskExecutor)
     
    void
    setVisibilityTimeout(Integer visibilityTimeout)
     
    void
    setWaitTimeOut(Integer waitTimeOut)
     
    void
    start(String logicalQueueName)
     
    void
    stop(String logicalQueueName)
     

    Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

    afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher

    Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

    doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setPhase, setRole, start, stop, stop

    Methods 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, toString

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.springframework.integration.support.context.NamedComponent

    getBeanName, getComponentName
  • Constructor Details

    • SqsMessageDrivenChannelAdapter

      public SqsMessageDrivenChannelAdapter(AmazonSQSAsync amazonSqs, String... queues)
  • Method Details

    • setTaskExecutor

      public void setTaskExecutor(org.springframework.core.task.AsyncTaskExecutor taskExecutor)
    • setMaxNumberOfMessages

      public void setMaxNumberOfMessages(Integer maxNumberOfMessages)
    • setVisibilityTimeout

      public void setVisibilityTimeout(Integer visibilityTimeout)
    • setWaitTimeOut

      public void setWaitTimeOut(Integer waitTimeOut)
    • setResourceIdResolver

      public void setResourceIdResolver(io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver)
    • setAutoStartup

      public void setAutoStartup(boolean autoStartUp)
      Overrides:
      setAutoStartup in class org.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:
      onInit in class org.springframework.integration.endpoint.MessageProducerSupport
    • getComponentType

      public String getComponentType()
      Specified by:
      getComponentType in interface org.springframework.integration.support.context.NamedComponent
      Overrides:
      getComponentType in class org.springframework.integration.context.IntegrationObjectSupport
    • doStart

      protected void doStart()
      Overrides:
      doStart in class org.springframework.integration.endpoint.MessageProducerSupport
    • doStop

      protected void doStop()
      Overrides:
      doStop in class org.springframework.integration.endpoint.MessageProducerSupport
    • stop

      @ManagedOperation public void stop(String logicalQueueName)
    • start

      @ManagedOperation public void start(String logicalQueueName)
    • isRunning

      @ManagedOperation public boolean isRunning(String logicalQueueName)
    • getQueues

      @ManagedAttribute public String[] getQueues()
    • destroy

      public void destroy()
      Specified by:
      destroy in interface org.springframework.beans.factory.DisposableBean
      Overrides:
      destroy in class org.springframework.integration.endpoint.AbstractEndpoint