То, что вы ищете, - это активный поставщик (например, Supplier<Flux>
).
В вашем случае это выглядело бы примерно так:
@SpringBootApplication
public class SomeApplication {
@Bean
public Supplier<Flux<Message<String>>> messageProducer() {
return () -> Flux.just(MessageBuilder.withPayload(textMessage).setHeader("service", "test").build());
}
}
Предоставьте свойство spring.cloud.function.definition=messageProducer
, и это в значительной степени так.
Очевидно, что в приведенном выше примере получен конечный поток с одним элементом, но вы можете свободно изменять возвращаемый поток. На самом деле мы обсудим это более подробно здесь .