0

我们使用SubscribableChannel,MessageChannelPollableMessageSource配置使用@EnableBindingand @StreamListner。现在我们需要迁移到函数式方法。SubscribableChannel并且MessageChannel可以使用 Consumer 和 Supplier bean 进行转换,但我们无法 migrate PollableMessageSource。由于如果我们使用,功能会被禁用@EnableBinding,因此我们被困在迁移中。我们尝试调查,@PollableBean但似乎它仅适用于具有有限流的 Reactive Supplier。有什么办法吗?参考:https ://cloud.spring.io/spring-cloud-stream/reference/html/spring-cloud-stream.html

4

1 回答 1

0

您可以将函数和 a 包装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为例。

于 2020-08-21T13:13:55.590 回答