1、需求,在一个服务内,消息发送和消息接收spring
2、根据网上或者书中处理以下:app
3、结果:报错,this
Invalid bean definition with name 'input' defined in XXXX.SinkSender: bean definition with this name already existsinput
4、分析缘由it
上图能够看出,@EnableBinding的Sink.class和SinkSender.class中,@Input和@Output都定义了名称相同的Sink.INPUT致使io
5、处理方式class
application.yml修改以下:stream
spring: cloud: stream: bindings: input: destination: raw-sensor-data output: destination: raw-sensor-data
SinkSender修改以下:im