private Step buildVerifyTransferUsingSnapshotRepoStep(String restoreId,
                                                          SnapshotJobManagerConfig jobManagerConfig)
        throws Exception {
        File restoreDir = new File(ContentDirUtils.getSourcePath(restoreId, jobManagerConfig.getContentRootDir()));
        Restoration restore = this.restoreManager.get(restoreId);
        SnapshotRepoManifestReader reader =
            new SnapshotRepoManifestReader(this.snapshotContentItemRepo, restore.getSnapshot().getName());

        SnapshotContentItemVerifier writer =
            new SnapshotContentItemVerifier(restoreId,
                                            getRestoreMd5Manifest(restoreDir),
                                            restore.getSnapshot().getName(),
                                            restoreManager);
        SimpleStepFactoryBean<SnapshotContentItem, SnapshotContentItem> stepFactory = new SimpleStepFactoryBean<>();

        stepFactory.setJobRepository(jobRepository);
        stepFactory.setTransactionManager(transactionManager);
        stepFactory.setBeanName("verifyTransferUsingSnapshotRepo");
        stepFactory.setItemReader(reader);
        stepFactory.setItemWriter(writer);
        stepFactory.setCommitInterval(50);
        stepFactory.setThrottleLimit(1);
        stepFactory.setTaskExecutor(taskExecutor);
        stepFactory.setListeners(new StepListener[] {writer});
        return stepFactory.getObject();
    }
private Step buildVerifyTransferUsingSnapshotRepoStep ( String restoreId , SnapshotJobManagerConfig jobManagerConfig ) throws Exception { File restoreDir = new File ( ContentDirUtils . getSourcePath ( restoreId , jobManagerConfig . getContentRootDir ( ) ) ) ; Restoration restore = this . restoreManager . get ( restoreId ) ; SnapshotRepoManifestReader reader = new SnapshotRepoManifestReader ( this . snapshotContentItemRepo , restore . getSnapshot ( ) . getName ( ) ) ; SnapshotContentItemVerifier writer = new SnapshotContentItemVerifier ( restoreId , getRestoreMd5Manifest ( restoreDir ) , restore . getSnapshot ( ) . getName ( ) , restoreManager ) ; SimpleStepFactoryBean < SnapshotContentItem , SnapshotContentItem > stepFactory = new SimpleStepFactoryBean < > ( ) ; stepFactory . setJobRepository ( jobRepository ) ; stepFactory . setTransactionManager ( transactionManager ) ; stepFactory . setBeanName ( "verifyTransferUsingSnapshotRepo" ) ; stepFactory . setItemReader ( reader ) ; stepFactory . setItemWriter ( writer ) ; stepFactory . setCommitInterval ( 50 ) ; stepFactory . setThrottleLimit ( 1 ) ; stepFactory . setTaskExecutor ( taskExecutor ) ; stepFactory . setListeners ( new StepListener [ ] { writer } ) ; return stepFactory . getObject ( ) ; }
@param restoreId
@param jobManagerConfig
@return