Мне нужна помощь в том, как сохранить количество сообщений в очереди RabbitMQ для объекта. поэтому эти данные могут использоваться некоторыми другими функциями. Я нашел несколько ответов, но не для загрузки Spring. Пожалуйста помоги!Количество сообщений в очереди rabbitMQ с использованием весенней загрузки
0
A
ответ
0
Протокол AMQP в приложении Spring Boot основан на проекте Spring AMQP.
Для вашей задачи, чтобы достичь, как высокий уровень API, насколько это возможно вы можете сделать так:
@Autowired
private RabbitTemplate rabbitTemplate;
...
AMQP.Queue.DeclareOk declareOk = this.rabbitTemplate.execute(channel ->
channel.queueDeclare(QUEUE_NAME, true, false, false, queueArgs));
declareOk.getMessageCount();
и применить соответствующие параметры очереди для этого queueDeclare()
.