如何在spring集成中使用shedlock?

iq0todco  于 2021-07-24  发布在  Java
关注(0)|答案(1)|浏览(477)

我将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 但我想知道如何使用这个棚屋。

2sbarzqh

2sbarzqh1#

从您的描述中根本不清楚您将如何使用该锁,但是根据本文,它看起来与spring集成没有任何关系。
另一方面,即使我不熟悉库,添加一个 LockRegistry shedlock到spring集成的实现。虽然这可能与你的任务无关。。。

相关问题