Class DirectMessageListenerContainerSpec

java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec<DirectMessageListenerContainerSpec,org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer>
org.springframework.integration.amqp.dsl.DirectMessageListenerContainerSpec
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.DirectMessageListenerContainer>, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

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

    • listenerContainer

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

    • DirectMessageListenerContainerSpec

      public DirectMessageListenerContainerSpec(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)
  • Method Details

    • consumersPerQueue

      public DirectMessageListenerContainerSpec consumersPerQueue(int consumersPerQueue)
      Parameters:
      consumersPerQueue - the consumersPerQueue.
      Returns:
      the spec.
      See Also:
      • DirectMessageListenerContainer.setConsumersPerQueue(int)
    • messagesPerAck

      public DirectMessageListenerContainerSpec messagesPerAck(int messagesPerAck)
      Parameters:
      messagesPerAck - the messages per ack.
      Returns:
      the spec.
      See Also:
      • DirectMessageListenerContainer.setMessagesPerAck(int)
    • ackTimeout

      public DirectMessageListenerContainerSpec ackTimeout(long ackTimeout)
      Parameters:
      ackTimeout - the ack timeout.
      Returns:
      the spec.
      See Also:
      • DirectMessageListenerContainer.setAckTimeout(long)