添加Stream之后启动问题:

Question

1.将两个input 更改成不同名称之后 启动报这个错:
我可以确保端口没被占用; 这里pom文件我是直接复制老师的,然后去除一些不用的;
自己试过的方法,自己生成一个对象注入,也是没有用

@Component
public class FeignBeanFactoryPostProcessor implements BeanFactoryPostProcessor { ....}

--------------------------------------------以下是错误提示:--------------------------------------

org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'eurekaAutoServiceRegistration': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)

Answer 1

廖师兄 2019-05-31 15:14:38

日志和代码要格式化呀，否则没办法看

Answer 2

提问者 慕后端2513554 2019-05-30 22:25:02

这里是自己解决了,同时还有个疑问

解决步骤

1.手动添加对象

@Component
public class FeignBeanFactoryPostProcessor implements BeanFactoryPostProcessor { …}

这里直接启动还是会报错:

A method annotated with @StreamListener having a return type should also have an outbound target specifiedat org.springframework.cloud.stream.binding.StreamListenerMethodUtils.validateStreamListenerMethod

2.需要在 StreamReceiver 里面任意方法上开启注解
@SendTo(StreamClient.INPUT2)

------疑问----

这里看错误提示是需要 sendto 注解 ,为什么需要 ,看老师视频上的是不需要的..

• 廖师兄 #1

  你用的版本是不是跟我的不一样，stream不同版本，差别挺大