SpringCloudStream配置,StreanClient接口中的myMessage Bean重复错误

来源:7-4 Spring Cloud Stream的使用(上)

萌白在努力

2018-05-12

http://img.mukewang.com/szimg/5af6cb7c0001878e17770623.jpg

改变@Output("myMessage")中的myMessage使得其与@Input的值不一样,就可以正常运行。

我切换过三个版本的stream,还是没用,原来用的是2.0.0.RELEASE的版本

http://img.mukewang.com/szimg/5af6cbed0001cc2c06710143.jpg

写回答

4回答

水煮米波

2018-11-28

SpringCloud F版本后,对应的2.1版本Spring Cloud Stream就是不允许相同的bean出现。这个问题我也被坑了好久。

0
0

曹仪

2018-11-01

public interface StreamClient {

   String INPUT = "myMessage";

   @Input(StreamClient.INPUT)
   SubscribableChannel input();
}

@RestController
public class SendMessageController {

   @Autowired
   private StreamClient streamClient;

   @GetMapping("/sendMessage")
   public void process(){
       String message = "now"+new Date();
       streamClient.input().send(MessageBuilder.withPayload(message).build());
   }
}


定义一个就可以了.

//img.mukewang.com/szimg/5bdabeb6000119f515950863.jpg

0
0

夏析

2018-05-14

@Input("myMessageInput")
SubscribableChannel input();

@Output("myMessageOutput")
MessageChannel output();


没办法只能这样了

0
0

殇腥黯皓

2018-05-13

我也遇到了这个,后来试了把消息推送和接收放在不同的项目,就不会有重复的bean定义了

0
1
涿鹿老王
这是肯定的,但是我很奇怪老师的版本既然可以重复beanname。真懵了
2018-07-06
共1条回复

SpringCloud Finchley(M2+RELEASE+SR2)微服务实战

SpringCloud组件实现微服务,【已升级Finchley.Release】

5672 学习 · 2489 问题

查看课程