Spring AMQP RabbitMQ 에 메 시 지 를 보 내 는 중 x-quue-type 오류 가 발생 했 습 니 다.

1381 단어 amqp
Spring AMQP 를 사용 하여 RabbitMQ 에 메 시 지 를 보 낼 때 오류 메 시 지 를 받 았 습 니 다.
inequivalent arg 'x-queue-type' for queue 'com.ossez.real.estate' in vhost '/': received none but current is the value 'classic' of type 'longstr', class-id=50, method-id=10
위의 오류 정 보 는 이미 매우 뚜렷 하 다.메 시 지 를 보 내 는 대기 열 매개 변수 가 적 다 는 것 을 설명 한다. x-queue-type 이 인자 입 니 다.
코드 에서 대기 열 을 만 드 는 매개 변 수 는 다음 과 같 습 니 다.
return new Queue(MY_QUEUE_NAME, NON_DURABLE);

이 직접 대기 열 을 만 드 는 매개 변 수 는 args.pt("x-queue-type","classic")이 적 습 니 다.
따라서 대기 열 을 만 들 때 위의 인 자 를 추가 해 야 합 니 다.
코드 변경:
Map args = new HashMap<>();// // set the queue with a dead letter featureargs.put("x-queue-type", "classic");return new Queue(MY_QUEUE_NAME, NON_DURABLE, false, false, args);

GitHub 의 코드 를 참고 하 세 요:
https://github.com/cwiki-us-demo/tutorials/blob/master/spring-amqp/src/main/java/com/baeldung/springamqp/simple/HelloWorldMessageApp.java
https://blog.ossez.com/archives/3050

좋은 웹페이지 즐겨찾기