spring-cloud-stream - 有没有办法在春云流中启动和停止所有流？

Question

我有一种情况，在开始处理流之前我需要在启动时执行一些任务。这可能吗？

标签： spring-cloud-stream

Answer 1

假设您使用功能绑定定义，您可以在返回处理函数之前调用任何方法：

@Bean
public Function<String, String> function() {
    init();
    return (x) -> {
        return x;
    };
}

private void init() {
     // initialize ..
}

您可以在docs中找到有关配置的更多详细信息。