스프링 AMQP에서 스프링 클라우드 스트림 마이그레이션 - 기존 큐

Question

RabbitMQ와 함께 Spring AMQP를 사용하는 기존 프로젝트에 Spring Cloud Stream을 추가하려고한다.

나는 다음과 같은 토끼 구성이 :

생산자 교환 이름 : producer.mail-sent.exchange

소비자 대기열 이름 : 생산자의 측면에서 consumer.mail-sent.queue

I는 다음과 같이 구성 : spring: cloud: stream: bindings: output: contentType: application/json destination: producer.mail-sent.exchange

그리고 사용 다음 코드 :

다음 코드와 spring: cloud: stream: bindings: input: contentType: application/json destination: producer.mail-sent.exchange group: consumer.mail-sent.queue

: 소비자의 측면에서

나는 다음과 같은 설정이

@EnableBinding(Sink.class) 
... 
@StreamListener(Sink.INPUT) 
public void handle(String someStuff) { 
    log.info("some stuff is received: " + someStuff); 
} 

을 그리고 작동 것으로 보인다. :) 하지만! 토끼쪽에는 producer.mail-sent.exchange.consumer.mail-sent.queue이라는 새로운 대기열이 있는데, 나는 그것이 consumer.mail-sent.queue이라는 기존 대기열을 사용하기를 원합니다.

이것을 달성 할 방법이 있습니까?

Answer 1

현재 지원되지 않습니다. (라우팅 키 등) 많은 속성을 구성 할 수 있지만 큐 이름은 항상 <destination>.<group>입니다.

기존 응용 프로그램에서 사용하려면 @StreamListener 대신 @RabbitListner을 사용하십시오.

GitHub Issue이 게시물을 참조하여 자유롭게 열리십시오 - 라우팅 키와 같은 다른 많은 "의견이있는"구성 설정은 구성 가능하지만 대기열 이름 자체는 아닙니다. 아마도 includeDestInQueueName이라는 부울을 추가 할 수 있습니다. 문제에서이 질문을 참조하십시오.