我们正在使用 SubscribableChannel , MessageChannel 以及 PollableMessageSource 并使用 @EnableBinding 以及 @StreamListner . 现在我们需要迁移到函数方法。 SubscribableChannel 以及 MessageChannel 可以使用消费者和供应商bean进行转换，但我们无法迁移 PollableMessageSource . 因为如果我们使用 @EnableBinding 因此，我们被困在迁移。我们试着调查 @PollableBean 但似乎它只适用于有限流的React型供应商。有什么办法吗？裁判：https://cloud.spring.io/spring-cloud-stream/reference/html/spring-cloud-stream.html
1条答案
按热度按时间ut6juiuv1#
可以 Package 函数和
PollableMessageSource在bean中使用@EnableBinding而不是绑定到函数。看到了吗https://github.com/spring-cloud/stream-applications/blob/master/applications/sink/tasklauncher-sink/src/main/java/org/springframework/cloud/stream/app/tasklauncher/sink/tasklaunchersinkconfiguration.java 举个例子。