2017-01-31 4 views
0

Мне нужна помощь в том, как сохранить количество сообщений в очереди RabbitMQ для объекта. поэтому эти данные могут использоваться некоторыми другими функциями. Я нашел несколько ответов, но не для загрузки Spring. Пожалуйста помоги!Количество сообщений в очереди rabbitMQ с использованием весенней загрузки

ответ

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().