Я изучаю rabbitMq, и теперь я хочу знать, как просматривать содержимое очереди.
Прежде всего, я хочу, чтобы я погуглил этот вопрос и узнал о команде
python rabbitmqadmin list queues
Я написал 2 отдельных приложения.
отправитель:
@Autowired
private AmqpTemplate template;
...
for (int i = 0; i < 100; i++) {
template.convertAndSend("queue1", "message_" + i);
}
получатель:
@RabbitListener(queues = "queue1")
public void listenQueue1(String message, @Header(AmqpHeaders.DELIVERY_TAG) long tag) {
logger.info("Got message:[" + message + "]");
}
Если я запускаю эти приложения вместе - я вижу сообщения на стороне получателя.
Чтобы увидеть сообщения в очереди, я решил остановить receiver
и запустить sender
- я запускаю отправителя
- выполнить
python rabbitmqadmin list queues
и видим следующий результат:
+-----------------+----------+
| name | messages |
+-----------------+----------+
| query-example-6 | |
| queue1 | |
| queue2 | |
| queue3 | |
| queue4 | |
| queue5 | |
| queue6 | |
| queue7 | |
| queue8 | |
| queue9 | |
+-----------------+----------+
3. Затем я запускаю приемник и вижу логи, что приемник принял сообщения
Можете ли вы объяснить причину, по которой я не вижу сообщения в консоли?
Как просмотреть содержимое сообщений очереди.