Как потребительский QueueChannel с какой-то скоростью?

Question

Здесь - пример заполнения и обработки очереди. Но как обработать сообщение со скоростью? Как обрабатывать N сообщений в секунду?

ОБНОВЛЕНИЕ Здесь под "porcess": я имел в виду "dequeue". Например, как удалить N сообщений в секунду?

Answer 1

Вы можете написать все oop, как я упоминал ранее, с каким-то контролем скорости (например, через Thread.sleep как самый элементарный). Вы также можете попробовать использовать аннотацию @Scheduled.

Вот пример метода, который будет вызываться 100 раз в секунду

@Scheduled(fixedRate = 10)
public void dequeue() {
        //queue.poll(..)
}