有没有办法使用Spring Cloud函数方法轮询来自主题的消息？
我们使用subscribableChannel、messageChannel和pollableMessageSource，并使用@enablebinding和@streamlistner进行配置。现在我们需要迁移到函数方法。subscribableChannel和messageChannel可以使用消费者bean和供应商bean进行转换，但是我们不能迁移pollableMessageSource。因为如果我们使用@enablebinding，函数将被禁用，因此我们无法进行迁移。我们尝试研究@pollablebean，但它似乎只适用于具有有限流的反应性供应商。有什么办法做这件事吗？参考：https://cloud.spring.io/spring-cloud-stream/reference/html/spring-cloud-stream.html
共有1个答案
您可以将函数和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获得一个示例。
-
我需要调用一个方法：myMethod（双...选项卡），但我通过其他方法调用获取此数组的元素。现在我做的是： 但是有了它，myMethod是这样声明的： 我想知道如何使用bytebuddy来代替： 或 此外，属性“form”是一个动态检索方法，因此在“for”中执行的循环数永远不会相同。所以有时我可以调用这样的表单方法：或或
-
我在本地计算机上将一条太大的消息推送到Kafka消息主题中，现在我收到一个错误： 增加在这里并不理想，因为我实际上不想接受那么大的消息。
-
问题内容： 有没有办法使用泛型说“此方法返回”？ 当然，我想在子类中重写此方法，因此声明应与一起使用。 这是一个例子： 根本不起作用：我收到“类型不匹配：无法从Base转换为T”。如果我强制使用强制转换，则覆盖将失败。 问题答案： 不，无法表达这一点。只需声明该方法即可返回类的类型。Java具有协变返回类型，因此无论如何您都可以重写方法以返回更特定的类型。 如果您想为此添加一些标记，则可以随时引入
-
Spring HATEOAS提供了方便的ControllerLinkBuilder来创建指向控制器方法的链接，这些方法将作为HREF添加到返回给客户端的JSON/XML中。例如： ... 可能会生成类似以下内容的JSON： 然而... 我倾向于通过反向代理访问我的服务。我想大多数人可能会这样做。这让我可以在不同的端口上运行多个服务，但让我可以通过相同的基本URL访问它们。不幸的是，通过代理访问意味
-
我有一个使用SpringCloud配置的SpringBoot应用程序，但我想在SpringBootApps引导程序中加密SpringCloud配置密码。yml文件。有办法做到这一点吗？下面是一个例子。 Spring Boot应用程序bootstrap.yml
-
我正在编写一个JavaFractal Explorer，分形计算是多线程完成的。以前，我只是创建了一堆线程（系统有多少处理器内核就有多少）并将它们保存在一个数组中，但这会导致一些问题，而且不是很优雅，现在我想切换到执行器。 我需要的功能是： 用户可以随时选择要放大的分形图像的新区域，因此应该可以随时取消计算，并立即重新插入新任务 我的问题是Java ExecutorService（我使用Execu