java - Spring云流-RabbitMQ配置

Question

我正在使用 Spring Cloud Stream Java 学习 RabbitMq。对 mq 配置有疑问。

根据文件 -spring.cloud.stream.bindings.>channelName>.destination=dest1

我正在使用以下配置并且它正在工作 -

spring.cloud.stream.bindings.input.destination=dest1

但是，如果我像下面这样提及我的 channel 名称来代替输入，则它不起作用 -spring.cloud.stream.bindings.myChannel.destination=dest1

在我的类里面 -@INPUT('myChannel')

我的疑问是为什么当我提到类里面给出的 channel 名称时它不起作用

但是当我将默认值设置为 .input 时它就可以工作。 ..？

更新

MyInterface.java

String CHANNEL = myChannel;
@INPUT(CHANNEL )
SubscribableChannel subs();

MyListener.java

@StreamListener(MyInterface.CHANNEL)
public void queueMsg(String str) {
   System.out.println("Str msg = "+str);
}

应用程序.prop

#Below property working fine
spring.cloud.stream.bindings.input.destination=dest1
spring.cloud.stream.bindings.input.binder=rabbit


#Below property NOT working 
#spring.cloud.stream.bindings.myChannel.destination=dest1
#spring.cloud.stream.bindings.myChannel.binder=rabbit

Answer 1

在本例中， channel 名称是绑定(bind)名称input。

spring.cloud.stream.bindings.输入.destination=dest1

对于 RabbitMQ，目的地是我们将发布到的交换名称。

使用@Input("input")。

或者

spring.cloud.stream.bindings.myChannel.destination=dest1

如果它不起作用，您需要显示您的监听器和界面。