Я использую выпуск spring boot 2.1.1 и spring-boot-starter-amqp, @@ RabbitListener перестал принимать сообщения, хотя работал нормально. Когда я перезапустил потребительский API, он начал нормально работать.
Также из пользовательского интерфейса управления он не показывает потребителей в этой очереди.
- Версия Java 1.8
- Кластер RabbitMQ 3.7.11 (3 узла)
- Kubernetes
- Нет исключений на стороне клиента java или сервера rabbitmq.
Heartbeates и keepalive со значениями по умолчанию. Я попытался повторно синхронизировать очередь через rabbitmqctl, но он все еще не работал.
@Component public class Receiver { Logger logger = Logger.getLogger(Receiver.class); @RabbitListener(queues="test") public void recievedMessage(String msg) { logger.info("Recieved Message: " + msg); } }