Java 类org.springframework.batch.core.explore.support.MapJobExplorerFactoryBean 实例源码

@Bean
public JobExplorer jobExplorer() throws Exception {
    MapJobExplorerFactoryBean mapJobExplorerFactoryBean = new MapJobExplorerFactoryBean();
    mapJobExplorerFactoryBean.setRepositoryFactory(jobRepository());
    mapJobExplorerFactoryBean.afterPropertiesSet();
    return mapJobExplorerFactoryBean.getObject();
}

@Override
public JobExplorer getJobExplorer() throws Exception {
    MapJobExplorerFactoryBean explorer = new MapJobExplorerFactoryBean(
            this.factory);
    explorer.afterPropertiesSet();
    return explorer.getObject();
}

@Override
public JobExplorer getJobExplorer() throws Exception {
    MapJobExplorerFactoryBean explorer = new MapJobExplorerFactoryBean(
            this.factory);
    explorer.afterPropertiesSet();
    return explorer.getObject();
}

@Override
public JobExplorer getJobExplorer() throws Exception {
    MapJobExplorerFactoryBean explorer = new MapJobExplorerFactoryBean(
            this.factory);
    explorer.afterPropertiesSet();
    return explorer.getObject();
}

@PostConstruct
public void initialize() {
    try {
        if (this.dataSource == null) {
            log.warn("No datasource was provided...using a Map based JobRepository");

            if (this.transactionManager == null) {
                this.transactionManager = new ResourcelessTransactionManager();
            }

            final MapJobRepositoryFactoryBean jobRepositoryFactory = new MapJobRepositoryFactoryBean(
                    this.transactionManager);
            jobRepositoryFactory.afterPropertiesSet();
            this.jobRepository = jobRepositoryFactory.getObject();

            final MapJobExplorerFactoryBean jobExplorerFactory = new MapJobExplorerFactoryBean(jobRepositoryFactory);
            jobExplorerFactory.afterPropertiesSet();
            this.jobExplorer = jobExplorerFactory.getObject();
        } else {
            this.jobRepository = createJobRepository();

            final JobExplorerFactoryBean jobExplorerFactoryBean = new JobExplorerFactoryBean();
            jobExplorerFactoryBean.setDataSource(this.dataSource);
            jobExplorerFactoryBean.setTablePrefix(JobConfig.this.tablePrefix);
            jobExplorerFactoryBean.afterPropertiesSet();
            this.jobExplorer = jobExplorerFactoryBean.getObject();
        }

        this.jobLauncher = createJobLauncher();
    } catch (final Exception e) {
        throw new BatchConfigurationException(e);
    }
}

@PostConstruct
public void initialize() throws Exception {
    if (dataSource == null) {
        logger.warn("No datasource was provided...using a Map based JobRepository");

        if (this.transactionManager == null) {
            this.transactionManager = new ResourcelessTransactionManager();
        }

        MapJobRepositoryFactoryBean jobRepositoryFactory = new MapJobRepositoryFactoryBean(this.transactionManager);
        jobRepositoryFactory.afterPropertiesSet();
        this.jobRepository = jobRepositoryFactory.getObject();

        MapJobExplorerFactoryBean jobExplorerFactory = new MapJobExplorerFactoryBean(jobRepositoryFactory);
        jobExplorerFactory.afterPropertiesSet();
        this.jobExplorer = jobExplorerFactory.getObject();
    } else {
        this.jobRepository = createJobRepository();

        JobExplorerFactoryBean jobExplorerFactoryBean = new JobExplorerFactoryBean();
        jobExplorerFactoryBean.setDataSource(this.dataSource);
        String tablePrefix = env.getProperty("batch.repository.tableprefix");
        if (tablePrefix != null) {
            jobExplorerFactoryBean.setTablePrefix(tablePrefix);
        }
        jobExplorerFactoryBean.afterPropertiesSet();
        this.jobExplorer = jobExplorerFactoryBean.getObject();
    }

    this.jobLauncher = createJobLauncher();
}

@PostConstruct
public void initialize() {
    try {
        if (dataSource == null) {
            logger.warn("No datasource was provided...using a Map based JobRepository");

            if (this.transactionManager == null) {
                this.transactionManager = new ResourcelessTransactionManager();
            }

            MapJobRepositoryFactoryBean jobRepositoryFactory = new MapJobRepositoryFactoryBean(
                    this.transactionManager);
            jobRepositoryFactory.afterPropertiesSet();
            this.jobRepository = jobRepositoryFactory.getObject();

            MapJobExplorerFactoryBean jobExplorerFactory = new MapJobExplorerFactoryBean(
                    jobRepositoryFactory);
            jobExplorerFactory.afterPropertiesSet();
            this.jobExplorer = jobExplorerFactory.getObject();
        } else {
            this.jobRepository = createJobRepository();

            JobExplorerFactoryBean jobExplorerFactoryBean = new JobExplorerFactoryBean();
            jobExplorerFactoryBean.setDataSource(this.dataSource);
            jobExplorerFactoryBean.afterPropertiesSet();
            this.jobExplorer = jobExplorerFactoryBean.getObject();
        }

        this.jobLauncher = createJobLauncher();
    } catch (Exception e) {
        throw new BatchConfigurationException(e);
    }
}

@Override
public JobExplorer getJobExplorer() throws Exception {
    return new MapJobExplorerFactoryBean(this.jobRepositoryFactory).getObject();
}

@Override
public JobExplorer getJobExplorer() throws Exception {
    return new MapJobExplorerFactoryBean(this.jobRepositoryFactory).getObject();
}

@Override
public JobExplorer getJobExplorer() throws Exception {
    return new MapJobExplorerFactoryBean(this.jobRepositoryFactory).getObject();
}