나는 간단한 RabbitMQ 테스트 프로그램을 무작위로 메시지를 대기시키고 있고, 다른 하나는 Spring-AMQP를 사용하고있다. 소비자가 사망 한 경우 (예 : 연결 또는 채널을 닫을 기회없이 프로세스를 종료하는 경우) 승인되지 않은 메시지는 영원히 미확인 상태로 남습니다. 채널이 연결되어 있지 않을 때 채널이 종료되고 나머지 unack'd 메시지가 다
"StatefulRetryOperationsInterceptor"클래스에 문제가 있습니다. 인터넷에 소스 예제가 없어서 사용법을 모르므로 도움을 청합니다. :) 따라서이 수업의 사용 경험이 있다면 여기에 간단한 소스 예제를 게시 할 수 있습니까? 감사드립니다. 감사합니다.
RabbitTemplate 클래스를 사용하여 spring amqp로 RabbitMQ 큐에 쓰고 있습니다. convertAndSend 메서드를 사용하여 메시지를 큐에 보냅니다. 이는 정상적인 상황에서는 잘 작동하지만 대기열이 없으면 자동으로 실패하는 것 같습니다. 예외가 발생하지 않고 오류/디버그 메시지가 로거에 기록되지 않습니다. 메시지 배달 여부를 확인하