У меня есть приложение, которое использует ArrayBlockingQueue для извлечения информации (из REST) и извлечения ее для внутренних процессов.В настоящее время у этого есть единственный поток, посвященный этой обработке (я настраивал это вручную).
Я использовал @JmsListener в прошлом с ActiveMQ, который позволяет объединять и т. Д.
IМне было интересно, если вместо этого есть эквивалент для обработки локальных переменных, так как в разработке достаточно одного потока, но в живом вам может понадобиться больше.
Например, я думаю о чем-то вроде:
private ArrayBlockingQueue sampleQueue;
@QueueListener(queue=sampleQueue, ...)
private void executeQueue(...) {
...
}
Даже если конфигурация сильно отличается или если мне нужно реализовать другую очередь, было бы идеально, если бы управление пулами и т. Д. Осуществлялось Spring.
У кого-нибудь есть идеи??Спасибо