Добрый день!
Кто нибудь использует Spring Cloud Stream версии 3.1+, то есть с Functional Programming Model? С версии 3.1+ они используют классы java.util.function.*: Supplier, Function, и Consumer. Они депрекейтнули
@EnableBinding,
@Input,
@Output,
@StreamListener и
@StreamMessageConverter. Функциональном подходе почему-то они решили отправить сообщения каждую секунду. и не понятно как отправить сообщения с помощью Supplier. Возникают много вопросов: Почему автоматички отправляются сообщения каждую секунду (хотя эту периодичность можно менять в конфигах). В чем заключается логика и т.д? Поделитесь пожалуйста опытом.