Java JobParametersInvalidException类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.springframework.batch.core.JobParametersInvalidException类的典型用法代码示例。如果您正苦于以下问题：Java JobParametersInvalidException类的具体用法？Java JobParametersInvalidException怎么用？Java JobParametersInvalidException使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

JobParametersInvalidException类属于org.springframework.batch.core包，在下文中一共展示了JobParametersInvalidException类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testCreateGenericArchive

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@Test
public void testCreateGenericArchive() throws NoSuchJobException,
JobExecutionAlreadyRunningException, JobRestartException,
JobInstanceAlreadyCompleteException, JobParametersInvalidException, IOException {
	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();

	JobParameters jobParameters = new JobParameters(parameters);

	Job palmwebArchive = jobLocator.getJob("PalmWeb");
	assertNotNull("Palmweb must not be null",  palmwebArchive);
	JobExecution jobExecution = jobLauncher.run(palmwebArchive, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");
	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount() + " " + stepExecution.getCommitCount());
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:21，代码来源:PalmwebIntegrationTest.java

示例2: start

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
public void start() throws IOException, InterruptedException {
	List<JobExecution> jobExecutions = new ArrayList<>();
	// launch jobs
	jobExecutions.addAll(IntStream.range(0, this.cardinality).mapToObj(i -> {
		Job analysisJob = this.jobFactory.get();
		JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
		jobParametersBuilder.addString("id", analysisJob.getName() + "-" + i, true);
		try {
			return this.jobLauncher.run(analysisJob, jobParametersBuilder.toJobParameters());
		} catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
				| JobParametersInvalidException exception) {
			throw new RuntimeException(exception);
		}
	}).collect(Collectors.toList()));
	// wait for termination
	while (jobExecutions.stream().anyMatch(jobExecution -> jobExecution.getStatus().isRunning())) {
		Thread.sleep(1000);
	}
}

开发者ID:maenu，项目名称:kowalski，代码行数:20，代码来源:Application.java

示例3: launch

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@RequestMapping("/launch")
public String launch() throws JobExecutionAlreadyRunningException,
        JobRestartException, JobInstanceAlreadyCompleteException,
        JobParametersInvalidException {

    //JobParametersの内容を変更しないと同一のジョブ実行と思われるっぽい。
    //同一のジョブ実行だと思われたら二回目からは実行されない。
    //(一回目の実行が既に完了しているので)
    //とりあえずIDっぽいものを持たせて実行の要求の度にインクリメントすることで
    //何度も実行できるようになった。
    //cf. JobParametersIncrementer
    JobParameters jobParameters = new JobParametersBuilder().addLong(
            "simpleBatchId", idGenerator.getAndIncrement())
            .toJobParameters();
    JobExecution execution = launcher.run(job, jobParameters);

    return execution.toString();
}

开发者ID:backpaper0，项目名称:spring-boot-sandbox，代码行数:19，代码来源:BatchLauncherController.java

示例4: launch

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@Override
public void launch(JobLaunchRequest request) {
	Job job;
	try {
		job = jobLocator.getJob(request.getJob());
		Map<String, JobParameter> jobParameterMap = new HashMap<String,	JobParameter>();
		for(String parameterName : request.getParameters().keySet()) {
			jobParameterMap.put(parameterName, new JobParameter(request.getParameters().get(parameterName)));
		}
		JobParameters jobParameters = new JobParameters(jobParameterMap);
		try {
			jobLauncher.run(job, jobParameters);
		} catch (JobExecutionAlreadyRunningException jeare) {
			jobStatusNotifier.notify(new JobExecutionException(jeare.getLocalizedMessage()), request.getParameters().get("resource.identifier"));
		} catch (JobRestartException jre) {
			jobStatusNotifier.notify(new JobExecutionException(jre.getLocalizedMessage()), request.getParameters().get("resource.identifier"));
		} catch (JobInstanceAlreadyCompleteException jiace) {
			jobStatusNotifier.notify(new JobExecutionException(jiace.getLocalizedMessage()), request.getParameters().get("resource.identifier"));
		} catch (JobParametersInvalidException jpie) {
			jobStatusNotifier.notify(new JobExecutionException(jpie.getLocalizedMessage()), request.getParameters().get("resource.identifier"));
		}
	} catch (NoSuchJobException nsje) {
		jobStatusNotifier.notify(new JobExecutionException(nsje.getLocalizedMessage()), request.getParameters().get("resource.identifier"));
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:26，代码来源:JobLauncherImpl.java

示例5: testNotModifiedResponse

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 *
 * @throws IOException
 *             if a temporary file cannot be created.
 * @throws NoSuchJobException
 *             if SpeciesPageHarvestingJob cannot be located
 * @throws JobParametersInvalidException
 *             if the job parameters are invalid
 * @throws JobInstanceAlreadyCompleteException
 *             if the job has already completed
 * @throws JobRestartException
 *             if the job cannot be restarted
 * @throws JobExecutionAlreadyRunningException
 *             if the job is already running
 */
@Test
public final void testNotModifiedResponse() throws IOException,
NoSuchJobException, JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {
	Map<String, JobParameter> parameters = new HashMap<String, JobParameter>();
	parameters.put("query.string", new JobParameter("select i from Image i"));

	JobParameters jobParameters = new JobParameters(parameters);

	Job job = jobLocator.getJob("ImageProcessing");
	assertNotNull("ImageProcessing must not be null", job);
	JobExecution jobExecution = jobLauncher.run(job, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");

	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount());
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:38，代码来源:ImageProcessingJobIntegrationTest.java

示例6: launch

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@Override
public void launch(JobLaunchRequest request) {
	Job job;
	try {
		job = jobLocator.getJob(request.getJob());
		Map<String, JobParameter> jobParameterMap = new HashMap<String, JobParameter>();
		for(String parameterName : request.getParameters().keySet()) {
			jobParameterMap.put(parameterName, new JobParameter(request.getParameters().get(parameterName)));
		}

		JobParameters jobParameters = new JobParameters(jobParameterMap);
		jobLauncher.run(job, jobParameters);
	} catch (NoSuchJobException 
			| JobExecutionAlreadyRunningException
			| JobRestartException
			| JobInstanceAlreadyCompleteException
			| JobParametersInvalidException exception) {
			jobStatusNotifier.notify(new JobExecutionException(exception.getLocalizedMessage()), request.getParameters().get("job.configuration.id"));
	}
}

开发者ID:RBGKew，项目名称:powop，代码行数:21，代码来源:JobLauncherImpl.java

示例7: launchImmediately

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
private JobExecution launchImmediately(TaskExecutor taskExecutor, Job job, JobParameters jobParameters)
{
	try
	{
		SimpleJobLauncher launcher = new SimpleJobLauncher();
		launcher.setJobRepository(jobRepository);
		launcher.setTaskExecutor(taskExecutor);
		return launcher.run(job, jobParameters);
	}
	catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
			| JobParametersInvalidException e)
	{
		logger.error("Unexpected exception", e);
		throw YonaException.unexpected(e);
	}
}

开发者ID:yonadev，项目名称:yona-server，代码行数:17，代码来源:BatchTaskService.java

示例8: main

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException,
        JobInstanceAlreadyCompleteException, JobParametersInvalidException, DuplicateJobException {
    ConfigurableApplicationContext ctx = SpringApplication.run(Application.class, args);

    Job simpleJob = ctx.getBean("simpleJob", Job.class);
    JobRegistry jobRegistry = ctx.getBean("jobRegistry", JobRegistry.class);
    jobRegistry.register(new ReferenceJobFactory(simpleJob));
    
    //JobRepository jobRepository = ctx.getBean("jobRepository", JobRepository.class);
    //JobInstance jobInstance = jobRepository.createJobInstance("simpleJob", new JobParameters());
    // JobParameters jobParameters = ctx.getBean("basicParameters", JobParameters.class);
    //
    //JobRegistry jobRegistry = ctx.getBean("mapJobRegistry", JobRegistry.class);
    // jobRegistry.register();
    // jobLauncher.run(job, jobParameters);
}

开发者ID:selimok，项目名称:working-examples，代码行数:17，代码来源:Application.java

示例9: execute

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
protected void execute(Job job, JobParameters jobParameters)
		throws JobExecutionAlreadyRunningException, JobRestartException,
		JobInstanceAlreadyCompleteException, JobParametersInvalidException,
		JobParametersNotFoundException {
	JobParameters nextParameters = getNextJobParameters(job, jobParameters);
	if (nextParameters != null) {
		JobExecution execution = this.jobLauncher.run(job, nextParameters);
		if (this.publisher != null) {
			this.publisher.publishEvent(new JobExecutionEvent(execution));
		}
	}
}

开发者ID:vikrammane23，项目名称:https-github.com-g0t4-jenkins2-course-spring-boot，代码行数:13，代码来源:JobLauncherCommandLineRunner.java

示例10: run

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 * Runs the scheduled job.
 *
 * @throws JobParametersInvalidException
 * @throws JobInstanceAlreadyCompleteException
 * @throws JobRestartException
 * @throws JobExecutionAlreadyRunningException
 */
@Scheduled(fixedRate = RATE)
public void run() throws JobExecutionAlreadyRunningException,
        JobRestartException, JobInstanceAlreadyCompleteException,
        JobParametersInvalidException {
    JobParameters params = new JobParameters(new HashMap<String, JobParameter>() {
        private static final long serialVersionUID = 1L;
        {
            put("execDate", new JobParameter(new Date(), true));
        }
    });

    jobLauncher.run(job, params);
}

开发者ID:hosuaby，项目名称:signature-processing，代码行数:22，代码来源:JobScheduler.java

示例11: shouldTaskletWork

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@Test
public void shouldTaskletWork() throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException,
        JobParametersInvalidException {
    Map<String, JobParameter> params = Maps.newHashMap();
    params.put("test", new JobParameter("przodownik"));
    params.put("time", new JobParameter(new Date()));
    JobExecution execution = jobLauncher.run(simpleStringProcessorTask, new JobParameters(params));
    log.info("Exit Status :  {}", execution.getExitStatus());
    Assert.assertEquals(ExitStatus.COMPLETED, execution.getExitStatus());

}

开发者ID:przodownikR1，项目名称:springBatchJmsKata，代码行数:12，代码来源:SimpleStringProcessingTest.java

示例12: requestJob3

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@RequestMapping("/job3/{input_file_name}")
@ResponseBody
String requestJob3(@PathVariable("input_file_name") String inputFileName) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException{
	JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
	jobParametersBuilder.addString("INPUT_FILE_PATH", inputFileName);
	jobParametersBuilder.addLong("TIMESTAMP",new Date().getTime());
	
	jobLauncher.run(job3, jobParametersBuilder.toJobParameters());
    return "Job3!";
}

开发者ID:pauldeng，项目名称:aws-elastic-beanstalk-worker-spring-boot-spring-batch-template，代码行数:11，代码来源:RESTController.java

示例13: testMatchTaxa

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 *
 * @throws IOException
 *             if a temporary file cannot be created.
 * @throws NoSuchJobException
 *             if SpeciesPageHarvestingJob cannot be located
 * @throws JobParametersInvalidException
 *             if the job parameters are invalid
 * @throws JobInstanceAlreadyCompleteException
 *             if the job has already completed
 * @throws JobRestartException
 *             if the job cannot be restarted
 * @throws JobExecutionAlreadyRunningException
 *             if the job is already running
 */
@Test
public final void testMatchTaxa() throws IOException,
NoSuchJobException, JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {

	Session session = sessionFactory.openSession();
	Transaction tx = session.beginTransaction();

	List<Taxon> taxa = session.createQuery("from Taxon as taxon").list();
	solrIndexingListener.indexObjects(taxa);
	tx.commit();

	ClassPathResource input = new ClassPathResource("/org/emonocot/job/taxonmatch/input.csv");
	Map<String, JobParameter> parameters = new HashMap<String, JobParameter>();
	parameters.put("assume.accepted.matches", new JobParameter(Boolean.TRUE.toString()));
	parameters.put("input.file", new JobParameter(input.getFile().getAbsolutePath()));
	parameters.put("output.file", new JobParameter(File.createTempFile("output", "csv").getAbsolutePath()));

	JobParameters jobParameters = new JobParameters(parameters);

	Job taxonMatchingJob = jobLocator.getJob("TaxonMatching");
	assertNotNull("TaxonMatching must not be null", taxonMatchingJob);
	JobExecution jobExecution = jobLauncher.run(taxonMatchingJob, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");

	FileReader file = new FileReader(jobParameters.getParameters().get("output.file").getValue().toString());
	BufferedReader reader = new BufferedReader(file);
	assertNotNull("There should be an output file", reader);
	String ln;
	while ((ln = reader.readLine()) != null) {
		logger.debug(ln);
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:50，代码来源:TaxonMatchIntegrationTest.java

示例14: testNotModifiedResponse

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 *
 * @throws IOException
 *             if a temporary file cannot be created.
 * @throws NoSuchJobException
 *             if SpeciesPageHarvestingJob cannot be located
 * @throws JobParametersInvalidException
 *             if the job parameters are invalid
 * @throws JobInstanceAlreadyCompleteException
 *             if the job has already completed
 * @throws JobRestartException
 *             if the job cannot be restarted
 * @throws JobExecutionAlreadyRunningException
 *             if the job is already running
 */
@Test
public final void testNotModifiedResponse() throws IOException,
NoSuchJobException, JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {
	Session session = sessionFactory.openSession();
	Transaction tx = session.beginTransaction();

	List<Taxon> taxa = session.createQuery("from Taxon as taxon").list();
	solrIndexingListener.indexObjects(taxa);
	tx.commit();

	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();
	parameters.put("authority.name", new JobParameter("test"));
	String repository = properties.getProperty("test.resource.baseUrl");
	parameters.put("authority.uri", new JobParameter(repository + "iucn.json"));
	parameters.put("authority.last.harvested",
			new JobParameter(Long.toString((IUCNJobIntegrationTest.PAST_DATETIME.getMillis()))));


	JobParameters jobParameters = new JobParameters(parameters);

	Job job = jobLocator.getJob("IUCNImport");
	assertNotNull("IUCNImport must not be null", job);
	JobExecution jobExecution = jobLauncher.run(job, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");
	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount() + " " + stepExecution.getCommitCount());
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:50，代码来源:IUCNJobIntegrationTest.java

示例15: testCreateGenericArchive

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@Test
public void testCreateGenericArchive() throws NoSuchJobException,
JobExecutionAlreadyRunningException, JobRestartException,
JobInstanceAlreadyCompleteException, JobParametersInvalidException, IOException {
	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();
	parameters.put("specs.file", new JobParameter(specsFile.getFile().getAbsolutePath()));
	parameters.put("items.file", new JobParameter(itemsFile.getFile().getAbsolutePath()));
	parameters.put("taxon.file", new JobParameter(taxonFile.getFile().getAbsolutePath()));
	parameters.put("fields.terminated.by", new JobParameter(","));
	parameters.put("fields.enclosed.by", new JobParameter("\""));
	parameters.put("output.fields",new JobParameter("taxonID,description,language,license"));
	parameters.put("taxon.file.skip.lines", new JobParameter("1"));
	parameters.put("taxon.file.field.names", new JobParameter("taxonID,subfamily,subtribe,tribe,accessRights,bibliographicCitation,created,license,modified,references,rights,rightsHolder,acceptedNameUsage,acceptedNameUsageID,class,datasetID,datasetName,family,genus,infraspecificEpithet,kingdom,nameAccordingTo,namePublishedIn,namePublishedInID,namePublishedInYear,nomenclaturalCode,nomenclaturalStatus,order,originalNameUsage,originalNameUsageID,parentNameUsage,parentNameUsageID,phylum,scientificName,scientificNameAuthorship,scientificNameID,specificEpithet,subgenus,taxonRank,taxonRemarks,taxonomicStatus,verbatimTaxonRank"));
	parameters.put("taxon.file.delimiter", new JobParameter("\t"));
	parameters.put("taxon.file.quote.character", new JobParameter("\""));
	parameters.put("description.file.field.names", new JobParameter("taxonID,description,license,language,type,rights"));
	parameters.put("description.default.values", new JobParameter("license=http://creativecommons.org/licenses/by-nc-sa/3.0,language=EN,type=general,rights=© Copyright The Board of Trustees\\, Royal Botanic Gardens\\, Kew."));
	parameters.put("archive.file", new JobParameter(UUID.randomUUID().toString()));

	JobParameters jobParameters = new JobParameters(parameters);

	Job deltaToDwC = jobLocator.getJob("DeltaToDwC");
	assertNotNull("DeltaToDwC must not be null",  deltaToDwC);
	JobExecution jobExecution = jobLauncher.run(deltaToDwC, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");
	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount() + " " + stepExecution.getCommitCount());
	}

}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:35，代码来源:DeltaNaturalLanguageDwcIntegrationTest.java

示例16: testCreateGenericArchive

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
@Test
public void testCreateGenericArchive() throws NoSuchJobException,
JobExecutionAlreadyRunningException, JobRestartException,
JobInstanceAlreadyCompleteException, JobParametersInvalidException, IOException {
	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();
	parameters.put("species.specs.file", new JobParameter(speciesSpecsFile.getFile().getAbsolutePath()));
	parameters.put("species.items.file", new JobParameter(speciesItemsFile.getFile().getAbsolutePath()));
	parameters.put("species.taxon.file", new JobParameter(speciesTaxonFile.getFile().getAbsolutePath()));
	parameters.put("genera.specs.file", new JobParameter(generaSpecsFile.getFile().getAbsolutePath()));
	parameters.put("genera.items.file", new JobParameter(generaItemsFile.getFile().getAbsolutePath()));
	parameters.put("genera.taxon.file", new JobParameter(generaTaxonFile.getFile().getAbsolutePath()));
	parameters.put("images.file", new JobParameter(imagesFile.getFile().getAbsolutePath()));

	JobParameters jobParameters = new JobParameters(parameters);

	Job deltaToDwC = jobLocator.getJob("Grassbase");
	assertNotNull("Grassbase must not be null",  deltaToDwC);
	JobExecution jobExecution = jobLauncher.run(deltaToDwC, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");
	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount() + " " + stepExecution.getCommitCount());
	}

}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:29，代码来源:GrassbaseIntegrationTest.java

示例17: testNotModifiedResponse

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 *
 * @throws IOException
 *             if a temporary file cannot be created.
 * @throws NoSuchJobException
 *             if SpeciesPageHarvestingJob cannot be located
 * @throws JobParametersInvalidException
 *             if the job parameters are invalid
 * @throws JobInstanceAlreadyCompleteException
 *             if the job has already completed
 * @throws JobRestartException
 *             if the job cannot be restarted
 * @throws JobExecutionAlreadyRunningException
 *             if the job is already running
 */
@Test
public final void testNotModifiedResponse() throws IOException,
NoSuchJobException, JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {
	Session session = sessionFactory.openSession();
	Transaction tx = session.beginTransaction();

	List<Taxon> taxa = session.createQuery("from Taxon as taxon").list();
	solrIndexingListener.indexObjects(taxa);
	tx.commit();

	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();
	parameters.put("family", new JobParameter("Araceae"));
	parameters.put("authority.name", new JobParameter("test"));
	String repository = properties.getProperty("test.resource.baseUrl",
			"http://build.e-monocot.org/git/?p=emonocot.git;a=blob_plain;f=emonocot-harvest/src/test/resources/org/emonocot/job/common/");
	parameters.put("authority.uri", new JobParameter(repository + "list.xml"));

	//parameters.put("authority.uri", new JobParameter("http://data.gbif.org/ws/rest/occurrence/list?taxonconceptkey=6979&maxresults=1000&typesonly=true&format=darwin&mode=raw&startindex="));
	parameters.put("authority.last.harvested",
			new JobParameter(Long.toString((GBIFJobIntegrationTest.PAST_DATETIME.getMillis()))));


	JobParameters jobParameters = new JobParameters(parameters);

	Job job = jobLocator.getJob("GBIFImport");
	assertNotNull("GBIFImport must not be null", job);
	JobExecution jobExecution = jobLauncher.run(job, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");
	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount() + " " + stepExecution.getCommitCount());
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:54，代码来源:GBIFJobIntegrationTest.java

示例18: testNotModifiedResponse

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 *
 * @throws IOException
 *             if a temporary file cannot be created.
 * @throws NoSuchJobException
 *             if SpeciesPageHarvestingJob cannot be located
 * @throws JobParametersInvalidException
 *             if the job parameters are invalid
 * @throws JobInstanceAlreadyCompleteException
 *             if the job has already completed
 * @throws JobRestartException
 *             if the job cannot be restarted
 * @throws JobExecutionAlreadyRunningException
 *             if the job is already running
 */
@Test
public final void testNotModifiedResponse() throws IOException,
NoSuchJobException, JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {
	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();
	parameters.put("query.string", new JobParameter(
			"select t.id from Taxon t join t.parentNameUsage"));

	JobParameters jobParameters = new JobParameters(parameters);

	Job job = jobLocator
			.getJob("CalculateDerivedProperties");
	assertNotNull("CalculateDerivedProperties must not be null",
			job);
	JobExecution jobExecution = jobLauncher.run(job, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");

	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount());
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:42，代码来源:CalculateDerivedPropertiesJobIntegrationTest.java

示例19: testImportTaxa

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 *
 * @throws IOException
 *             if a temporary file cannot be created.
 * @throws NoSuchJobException
 *             if SpeciesPageHarvestingJob cannot be located
 * @throws JobParametersInvalidException
 *             if the job parameters are invalid
 * @throws JobInstanceAlreadyCompleteException
 *             if the job has already completed
 * @throws JobRestartException
 *             if the job cannot be restarted
 * @throws JobExecutionAlreadyRunningException
 *             if the job is already running
 */
@Test
public final void testImportTaxa() throws IOException,
NoSuchJobException, JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {
	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();
	parameters.put("authority.name", new JobParameter(
			"test"));
	parameters.put("family", new JobParameter(
			"Araceae"));
	parameters.put("taxon.processing.mode", new JobParameter("IMPORT_TAXA_BY_AUTHORITY"));
	String repository = properties.getProperty("test.resource.baseUrl");
	parameters.put("authority.uri", new JobParameter(repository + "dwc.zip"));
	parameters.put("authority.last.harvested",
			new JobParameter(Long.toString((TaxonImportingIntegrationTest.PAST_DATETIME.getMillis()))));
	JobParameters jobParameters = new JobParameters(parameters);

	Job darwinCoreArchiveHarvestingJob = jobLocator.getJob("DarwinCoreArchiveHarvesting");
	assertNotNull("DarwinCoreArchiveHarvesting must not be null", darwinCoreArchiveHarvestingJob);
	JobExecution jobExecution = jobLauncher.run(darwinCoreArchiveHarvestingJob, jobParameters);
	assertEquals("The job should complete successfully","COMPLETED",jobExecution.getExitStatus().getExitCode());
	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount());
	}

	//Test namePublishedIn is saved
	//        assertNotNull("The namePublishedIn should have been saved.",
	//                referenceService.find("urn:example.com:test:ref:numerouno"));
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:49，代码来源:TaxonImportingIntegrationTest.java

示例20: testImportTaxa

import org.springframework.batch.core.JobParametersInvalidException; //导入依赖的package包/类
/**
 *
 * @throws IOException
 *             if a temporary file cannot be created.
 * @throws NoSuchJobException
 *             if SpeciesPageHarvestingJob cannot be located
 * @throws JobParametersInvalidException
 *             if the job parameters are invalid
 * @throws JobInstanceAlreadyCompleteException
 *             if the job has already completed
 * @throws JobRestartException
 *             if the job cannot be restarted
 * @throws JobExecutionAlreadyRunningException
 *             if the job is already running
 */
@Test
public final void testImportTaxa() throws IOException,
NoSuchJobException, JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {
	Map<String, JobParameter> parameters =
			new HashMap<String, JobParameter>();
	parameters.put("authority.name", new JobParameter(
			"test"));
	parameters.put("family", new JobParameter(
			"Araceae"));
	parameters.put("key.processing.mode", new JobParameter("IMPORT_KEYS"));
	parameters.put("taxon.processing.mode", new JobParameter("IMPORT_TAXA_BY_AUTHORITY"));
	parameters.put("authority.uri", new JobParameter("http://build.e-monocot.org/oldtest/test.zip"));
	parameters.put("authority.last.harvested",
			new JobParameter(Long.toString((IdentificationKeyImportingIntegrationTest.PAST_DATETIME.getMillis()))));
	JobParameters jobParameters = new JobParameters(parameters);

	Job darwinCoreArchiveHarvestingJob = jobLocator
			.getJob("DarwinCoreArchiveHarvesting");
	assertNotNull("DarwinCoreArchiveHarvesting must not be null",
			darwinCoreArchiveHarvestingJob);
	JobExecution jobExecution = jobLauncher.run(darwinCoreArchiveHarvestingJob, jobParameters);
	assertEquals("The job should complete successfully",jobExecution.getExitStatus().getExitCode(),"COMPLETED");
	for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
		logger.info(stepExecution.getStepName() + " "
				+ stepExecution.getReadCount() + " "
				+ stepExecution.getFilterCount() + " "
				+ stepExecution.getWriteCount());
	}
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:47，代码来源:IdentificationKeyImportingIntegrationTest.java

注：本文中的org.springframework.batch.core.JobParametersInvalidException类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java IWorkspaceDescription类代码示例发布时间：2022-05-21

Java DefaultOHLCDataset类代码示例发布时间：2022-05-21

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18871|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9884|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8289|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8643|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8575|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9580|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8570|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7961|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8575|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7501|2022-11-06

客服电话

电子邮件

Java JobParametersInvalidException类代码示例

示例1: testCreateGenericArchive

示例2: start

示例3: launch

示例4: launch

示例5: testNotModifiedResponse

示例6: launch

示例7: launchImmediately

示例8: main

示例9: execute

示例10: run

示例11: shouldTaskletWork

示例12: requestJob3

示例13: testMatchTaxa

示例14: testNotModifiedResponse

示例15: testCreateGenericArchive

示例16: testCreateGenericArchive

示例17: testNotModifiedResponse

示例18: testNotModifiedResponse

示例19: testImportTaxa

示例20: testImportTaxa

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

Haehnchen/idea-php-laravel-plugin: Larav

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053