java - 有没有办法使用 Spring Cloud Function 方法从主题中轮询消息？

Question

我们使用SubscribableChannel,MessageChannel和PollableMessageSource配置使用@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

Answer 1

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