Package org.springframework.amqp.rabbit.config

Class DirectRabbitListenerContainerFactory

    • Constructor Detail

      • DirectRabbitListenerContainerFactory

        public DirectRabbitListenerContainerFactory()

    • Method Detail

      • setTaskScheduler

        public void setTaskScheduler​(TaskScheduler taskScheduler)
        Set the task scheduler to use for the task that monitors idle containers and failed consumers.
        Parameters:
        taskScheduler - the scheduler.

      • setMonitorInterval

        public void setMonitorInterval​(long monitorInterval)
        Set how often to run a task to check for failed consumers and idle containers.
        Parameters:
        monitorInterval - the interval; default 10000 but it will be adjusted down to the smallest of this, idleEventInterval / 2 (if configured) or failedDeclarationRetryInterval.

      • setConsumersPerQueue

        public void setConsumersPerQueue​(Integer consumersPerQueue)
        Each queue runs in its own consumer; set this property to create multiple consumers for each queue. If the container is already running, the number of consumers per queue will be adjusted up or down as necessary.
        Parameters:
        consumersPerQueue - the consumers per queue.

      • setMessagesPerAck

        public void setMessagesPerAck​(Integer messagesPerAck)
        Set the number of messages to receive before acknowledging (success). A failed message will short-circuit this counter.
        Parameters:
        messagesPerAck - the number of messages.
        See Also:
        setAckTimeout(Long)

      • setAckTimeout

        public void setAckTimeout​(Long ackTimeout)
        An approximate timeout; when messagesPerAck is greater than 1, and this time elapses since the last ack, the pending acks will be sent either when the next message arrives, or a short time later if no additional messages arrive. In that case, the actual time depends on the monitorInterval.
        Parameters:
        ackTimeout - the timeout in milliseconds (default 20000);
        See Also:
        setMessagesPerAck(Integer)