我将spring批处理和spring集成结合起来,我将poller与玉米一起使用:
@Bean
@SchedulerLock(name = "importEntitiesRiskCodes", lockAtMostForString = "PT5M")
public IntegrationFlow integrationFlow() {
return IntegrationFlows.from(fileReadingMessageSource(),
c -> c.poller(Pollers.cron("0-7 1-59/5 * * * ?").maxMessagesPerPoll(maxFilesPerPoll)))
.channel(fileIn())
.transform(fileMessageToJobrequest())
.handle(jobLaunchingGateway())
.log()
.get();
}
我知道spring集成jdbc提供 JDBCLockRepository
但我想知道如何使用这个棚屋。
1条答案
按热度按时间2sbarzqh1#
从您的描述中根本不清楚您将如何使用该锁,但是根据本文,它看起来与spring集成没有任何关系。
另一方面,即使我不熟悉库,添加一个
LockRegistry
shedlock到spring集成的实现。虽然这可能与你的任务无关。。。