Я разработал данные Spring Cloud, которые у меня есть Source - Transform - Sink, но источник не собирается каждые 3 минуты, у меня есть этот как application.properties -> poller.cron=1-59/2 * * * * *
Но, похоже, он делает только один раз вместо запуска источника для преобразования в сток каждые 3 минуты. Любая помощь ценится
@SpringBootApplication
@EnableBinding(Source.class)
public class FetchFromDbApplication {
Logger logger = LoggerFactory.getLogger(FetchFromDbApplication.class);
@Autowired
CustomerService customerService;
@Bean
@InboundChannelAdapter(
value = Source.OUTPUT,
poller = @Poller(cron = "${poller.cron}", maxMessagesPerPoll = "1")
)
public MessageSource<List<Customer>> processCustomer() { this one will run the query and fetch the customers to transform and then to sink}..