Два Потребителя в одном классе. Остановите Потребителя A, пока очередь Потребителя B не станет пустой - PullRequest
0 голосов
/ 18 января 2019

Я объявил один канал, объявленный хосту rabbitmq. У меня есть два потребителя (A и B), которые подключены к разным очередям. Можно ли остановить потребителя A до тех пор, пока очередь потребителя B не станет (почти) пустой.

Я думал об установке какого-то приоритета, но не нашел правильного решения

try {
    channel.basicConsume(first_queue, false, consumerA);

    channel.basicConsume(second_queue, false, consumerB);
} catch (Exception e) {
    log.error("failed to add consumer channel: " + e.getMessage());
    e.printStackTrace();
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...