Class SimpleMessageListenerContainerSpec

java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>
org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class SimpleMessageListenerContainerSpec extends AbstractMessageListenerContainerSpec<SimpleMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer>
Spec for a SimpleMessageListenerContainer.
Since:
5.0
  • Field Details

    • listenerContainer

      protected final org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer
  • Constructor Details

    • SimpleMessageListenerContainerSpec

      public SimpleMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
  • Method Details

    • concurrentConsumers

      public SimpleMessageListenerContainerSpec concurrentConsumers(int concurrentConsumers)
      Parameters:
      concurrentConsumers - the concurrentConsumers
      Returns:
      the spec.
      See Also:
      • SimpleMessageListenerContainer.setConcurrentConsumers(int)
    • maxConcurrentConsumers

      public SimpleMessageListenerContainerSpec maxConcurrentConsumers(int maxConcurrentConsumers)
      Parameters:
      maxConcurrentConsumers - the maxConcurrentConsumers.
      Returns:
      the spec.
      See Also:
      • SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)
    • startConsumerMinInterval

      public SimpleMessageListenerContainerSpec startConsumerMinInterval(long startConsumerMinInterval)
      Parameters:
      startConsumerMinInterval - the startConsumerMinInterval
      Returns:
      the spec.
      See Also:
      • SimpleMessageListenerContainer.setStartConsumerMinInterval(long)
    • stopConsumerMinInterval

      public SimpleMessageListenerContainerSpec stopConsumerMinInterval(long stopConsumerMinInterval)
      Parameters:
      stopConsumerMinInterval - the stopConsumerMinInterval.
      Returns:
      the spec.
      See Also:
      • SimpleMessageListenerContainer.setStopConsumerMinInterval(long)
    • consecutiveActiveTrigger

      public SimpleMessageListenerContainerSpec consecutiveActiveTrigger(int consecutiveActiveTrigger)
      Parameters:
      consecutiveActiveTrigger - the consecutiveActiveTrigger.
      Returns:
      the spec.
      See Also:
      • SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)
    • consecutiveIdleTrigger

      public SimpleMessageListenerContainerSpec consecutiveIdleTrigger(int consecutiveIdleTrigger)
      Parameters:
      consecutiveIdleTrigger - the consecutiveIdleTrigger.
      Returns:
      the spec.
      See Also:
      • SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)
    • receiveTimeout

      public SimpleMessageListenerContainerSpec receiveTimeout(long receiveTimeout)
      Parameters:
      receiveTimeout - the receiveTimeout
      Returns:
      the spec.
      See Also:
      • SimpleMessageListenerContainer.setReceiveTimeout(long)
    • batchSize

      public SimpleMessageListenerContainerSpec batchSize(int batchSize)
      The batch size to use.
      Parameters:
      batchSize - the batchSize.
      Returns:
      the spec.
      Since:
      5.2
      See Also:
      • SimpleMessageListenerContainer.setBatchSize(int)
    • consumerBatchEnabled

      public SimpleMessageListenerContainerSpec consumerBatchEnabled(boolean enabled)
      Set to true to enable batching of consumed messages.
      Parameters:
      enabled - true to enable.
      Returns:
      the spec.
      Since:
      5.3