org.camunda.bpm.engine.runtime.Job.getDeploymentId()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(20.5k)|赞(0)|评价(0)|浏览(78)

本文整理了Java中org.camunda.bpm.engine.runtime.Job.getDeploymentId()方法的一些代码示例,展示了Job.getDeploymentId()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Job.getDeploymentId()方法的具体详情如下:
包路径:org.camunda.bpm.engine.runtime.Job
类名称:Job
方法名:getDeploymentId

Job.getDeploymentId介绍

[英]Returns the id of the deployment in which context the job was created.
[中]返回创建作业的部署上下文的id。

代码示例

代码示例来源:origin: camunda/camunda-bpm-platform

private List<String> getJobIdsByDeployment(List<Job> jobs, String deploymentId) {
 List<String> jobIdsForDeployment = new LinkedList<String>();
 for (int i = 0; i < jobs.size(); i++) {
  if (jobs.get(i).getDeploymentId().equals(deploymentId)) {
   jobIdsForDeployment.add(jobs.get(i).getId());
  }
 }
 return jobIdsForDeployment;
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment(resources = "org/camunda/bpm/engine/test/jobexecutor/simpleAsyncProcess.bpmn20.xml")
public void testProcessingOfJobsWithMatchingDeployment() {
 runtimeService.startProcessInstanceByKey("simpleAsyncProcess");
 Set<String> registeredDeployments = managementService.getRegisteredDeployments();
 Assert.assertEquals(1, registeredDeployments.size());
 Assert.assertTrue(registeredDeployments.contains(deploymentId));
 Job executableJob = managementService.createJobQuery().singleResult();
 String otherDeploymentId =
   deployAndInstantiateWithNewEngineConfiguration(
     "org/camunda/bpm/engine/test/jobexecutor/simpleAsyncProcessVersion2.bpmn20.xml");
 // assert that two jobs have been created, one for each deployment
 List<Job> jobs = managementService.createJobQuery().list();
 Assert.assertEquals(2, jobs.size());
 Set<String> jobDeploymentIds = new HashSet<String>();
 jobDeploymentIds.add(jobs.get(0).getDeploymentId());
 jobDeploymentIds.add(jobs.get(1).getDeploymentId());
 Assert.assertTrue(jobDeploymentIds.contains(deploymentId));
 Assert.assertTrue(jobDeploymentIds.contains(otherDeploymentId));
 // select executable jobs for executor of first engine
 AcquiredJobs acquiredJobs = getExecutableJobs(processEngineConfiguration.getJobExecutor());
 Assert.assertEquals(1, acquiredJobs.size());
 Assert.assertTrue(acquiredJobs.contains(executableJob.getId()));
 repositoryService.deleteDeployment(otherDeploymentId, true);
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment(resources = {"org/camunda/bpm/engine/test/history/HistoricJobLogTest.testAsyncContinuation.bpmn20.xml"})
public void testQueryByDeploymentId() {
 runtimeService.startProcessInstanceByKey("process");
 String deploymentId = managementService.createJobQuery().singleResult().getDeploymentId();
 HistoricJobLogQuery query = historyService.createHistoricJobLogQuery().deploymentId(deploymentId);
 verifyQueryResults(query, 1);
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment
public void testPriorityInTimerCycleEvent() throws Exception {
 ClockUtil.setCurrentTime(new Date());
 // After process start, there should be timer created
 JobQuery jobQuery = managementService.createJobQuery();
 assertEquals(1, jobQuery.count());
 // ensure that the deployment Id is set on the new job
 Job job = jobQuery.singleResult();
 assertNotNull(job.getDeploymentId());
 assertEquals(9999, job.getPriority());
 final ProcessInstanceQuery piq = runtimeService.createProcessInstanceQuery()
  .processDefinitionKey("startTimerEventExampleCycle");
 assertEquals(0, piq.count());
 moveByMinutes(5);
 executeAllJobs();
 assertEquals(1, piq.count());
 assertEquals(1, jobQuery.count());
 // ensure that the deployment Id is set on the new job
 job = jobQuery.singleResult();
 assertNotNull(job.getDeploymentId());
 // second job should have the same priority
 assertEquals(9999, job.getPriority());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment
public void testCycleWithLimitStartTimerEvent() throws Exception {
 ClockUtil.setCurrentTime(new Date());
 // After process start, there should be timer created
 JobQuery jobQuery = managementService.createJobQuery();
 assertEquals(1, jobQuery.count());
 // ensure that the deployment Id is set on the new job
 Job job = jobQuery.singleResult();
 assertNotNull(job.getDeploymentId());
 final ProcessInstanceQuery piq = runtimeService.createProcessInstanceQuery().processDefinitionKey("startTimerEventExampleCycle");
 assertEquals(0, piq.count());
 moveByMinutes(5);
 executeAllJobs();
 assertEquals(1, piq.count());
 assertEquals(1, jobQuery.count());
 // ensure that the deployment Id is set on the new job
 job = jobQuery.singleResult();
 assertNotNull(job.getDeploymentId());
 moveByMinutes(5);
 executeAllJobs();
 assertEquals(2, piq.count());
 assertEquals(0, jobQuery.count());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Test
public void testMigrationJobsCreation() {
 ClockUtil.setCurrentTime(TEST_DATE);
 // reduce number of batch jobs per seed to not have to create a lot of instances
 engineRule.getProcessEngineConfiguration().setBatchJobsPerSeed(10);
 Batch batch = helper.migrateProcessInstancesAsync(20);
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 JobDefinition migrationJobDefinition = helper.getExecutionJobDefinition(batch);
 String sourceDeploymentId = helper.getSourceProcessDefinition().getDeploymentId();
 // when
 helper.executeSeedJob(batch);
 // then there exist migration jobs
 List<Job> migrationJobs = helper.getJobsForDefinition(migrationJobDefinition);
 assertEquals(10, migrationJobs.size());
 for (Job migrationJob : migrationJobs) {
  assertEquals(migrationJobDefinition.getId(), migrationJob.getJobDefinitionId());
  assertEquals(currentTime, migrationJob.getDuedate());
  assertEquals(sourceDeploymentId, migrationJob.getDeploymentId());
  assertNull(migrationJob.getProcessDefinitionId());
  assertNull(migrationJob.getProcessDefinitionKey());
  assertNull(migrationJob.getProcessInstanceId());
  assertNull(migrationJob.getExecutionId());
 }
 // and the seed job still exists
 Job seedJob = helper.getJobForDefinition(seedJobDefinition);
 assertNotNull(seedJob);
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Test
public void createSeedJobByIds() {
 // when
 Batch batch = historyService.deleteHistoricDecisionInstancesAsync(decisionInstanceIds, null);
 // then there exists a seed job definition with the batch id as
 // configuration
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 assertNotNull(seedJobDefinition);
 assertEquals(batch.getId(), seedJobDefinition.getJobConfiguration());
 assertEquals(BatchSeedJobHandler.TYPE, seedJobDefinition.getJobType());
 // and there exists a deletion job definition
 JobDefinition deletionJobDefinition = helper.getExecutionJobDefinition(batch);
 assertNotNull(deletionJobDefinition);
 assertEquals(Batch.TYPE_HISTORIC_DECISION_INSTANCE_DELETION, deletionJobDefinition.getJobType());
 // and a seed job with no relation to a process or execution etc.
 Job seedJob = helper.getSeedJob(batch);
 assertNotNull(seedJob);
 assertEquals(seedJobDefinition.getId(), seedJob.getJobDefinitionId());
 assertEquals(currentTime, seedJob.getDuedate());
 assertNull(seedJob.getDeploymentId());
 assertNull(seedJob.getProcessDefinitionId());
 assertNull(seedJob.getProcessDefinitionKey());
 assertNull(seedJob.getProcessInstanceId());
 assertNull(seedJob.getExecutionId());
 // but no deletion jobs where created
 List<Job> deletionJobs = helper.getExecutionJobs(batch);
 assertEquals(0, deletionJobs.size());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Test
public void testSeedJobCreation() {
 ClockUtil.setCurrentTime(TEST_DATE);
 // when
 Batch batch = helper.migrateProcessInstancesAsync(10);
 // then there exists a seed job definition with the batch id as configuration
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 assertNotNull(seedJobDefinition);
 assertEquals(batch.getId(), seedJobDefinition.getJobConfiguration());
 assertEquals(BatchSeedJobHandler.TYPE, seedJobDefinition.getJobType());
 // and there exists a migration job definition
 JobDefinition migrationJobDefinition = helper.getExecutionJobDefinition(batch);
 assertNotNull(migrationJobDefinition);
 assertEquals(Batch.TYPE_PROCESS_INSTANCE_MIGRATION, migrationJobDefinition.getJobType());
 // and a seed job with no relation to a process or execution etc.
 Job seedJob = helper.getSeedJob(batch);
 assertNotNull(seedJob);
 assertEquals(seedJobDefinition.getId(), seedJob.getJobDefinitionId());
 assertEquals(currentTime, seedJob.getDuedate());
 assertNull(seedJob.getDeploymentId());
 assertNull(seedJob.getProcessDefinitionId());
 assertNull(seedJob.getProcessDefinitionKey());
 assertNull(seedJob.getProcessInstanceId());
 assertNull(seedJob.getExecutionId());
 // but no migration jobs where created
 List<Job> migrationJobs = helper.getExecutionJobs(batch);
 assertEquals(0, migrationJobs.size());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Test
public void createSeedJobByQuery() {
 // given
 HistoricDecisionInstanceQuery query = historyService.createHistoricDecisionInstanceQuery().decisionDefinitionKey(DECISION);
 // when
 Batch batch = historyService.deleteHistoricDecisionInstancesAsync(decisionInstanceIds, query, null);
 // then there exists a seed job definition with the batch id as
 // configuration
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 assertNotNull(seedJobDefinition);
 assertEquals(batch.getId(), seedJobDefinition.getJobConfiguration());
 assertEquals(BatchSeedJobHandler.TYPE, seedJobDefinition.getJobType());
 // and there exists a deletion job definition
 JobDefinition deletionJobDefinition = helper.getExecutionJobDefinition(batch);
 assertNotNull(deletionJobDefinition);
 assertEquals(Batch.TYPE_HISTORIC_DECISION_INSTANCE_DELETION, deletionJobDefinition.getJobType());
 // and a seed job with no relation to a process or execution etc.
 Job seedJob = helper.getSeedJob(batch);
 assertNotNull(seedJob);
 assertEquals(seedJobDefinition.getId(), seedJob.getJobDefinitionId());
 assertEquals(currentTime, seedJob.getDuedate());
 assertNull(seedJob.getDeploymentId());
 assertNull(seedJob.getProcessDefinitionId());
 assertNull(seedJob.getProcessDefinitionKey());
 assertNull(seedJob.getProcessInstanceId());
 assertNull(seedJob.getExecutionId());
 // but no deletion jobs where created
 List<Job> deletionJobs = helper.getExecutionJobs(batch);
 assertEquals(0, deletionJobs.size());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Test
public void createSeedJob() {
 // when
 ProcessDefinition processDefinition = testRule.deployAndGetDefinition(instance);
 Batch batch = helper.startAfterAsync("process1", 3, "user1", processDefinition.getId());
 // then there exists a seed job definition with the batch id as
 // configuration
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 assertNotNull(seedJobDefinition);
 assertEquals(batch.getId(), seedJobDefinition.getJobConfiguration());
 assertEquals(BatchSeedJobHandler.TYPE, seedJobDefinition.getJobType());
 // and there exists a modification job definition
 JobDefinition modificationJobDefinition = helper.getExecutionJobDefinition(batch);
 assertNotNull(modificationJobDefinition);
 assertEquals(Batch.TYPE_PROCESS_INSTANCE_MODIFICATION, modificationJobDefinition.getJobType());
 // and a seed job with no relation to a process or execution etc.
 Job seedJob = helper.getSeedJob(batch);
 assertNotNull(seedJob);
 assertEquals(seedJobDefinition.getId(), seedJob.getJobDefinitionId());
 assertEquals(currentTime, seedJob.getDuedate());
 assertNull(seedJob.getDeploymentId());
 assertNull(seedJob.getProcessDefinitionId());
 assertNull(seedJob.getProcessDefinitionKey());
 assertNull(seedJob.getProcessInstanceId());
 assertNull(seedJob.getExecutionId());
 // but no modification jobs where created
 List<Job> modificationJobs = helper.getExecutionJobs(batch);
 assertEquals(0, modificationJobs.size());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Test
public void createSeedJobByIdsAndQuery() {
 // given
 HistoricDecisionInstanceQuery query = historyService.createHistoricDecisionInstanceQuery().decisionDefinitionKey(DECISION);
 // when
 Batch batch = historyService.deleteHistoricDecisionInstancesAsync(query, null);
 // then there exists a seed job definition with the batch id as
 // configuration
 JobDefinition seedJobDefinition = helper.getSeedJobDefinition(batch);
 assertNotNull(seedJobDefinition);
 assertEquals(batch.getId(), seedJobDefinition.getJobConfiguration());
 assertEquals(BatchSeedJobHandler.TYPE, seedJobDefinition.getJobType());
 // and there exists a deletion job definition
 JobDefinition deletionJobDefinition = helper.getExecutionJobDefinition(batch);
 assertNotNull(deletionJobDefinition);
 assertEquals(Batch.TYPE_HISTORIC_DECISION_INSTANCE_DELETION, deletionJobDefinition.getJobType());
 // and a seed job with no relation to a process or execution etc.
 Job seedJob = helper.getSeedJob(batch);
 assertNotNull(seedJob);
 assertEquals(seedJobDefinition.getId(), seedJob.getJobDefinitionId());
 assertEquals(currentTime, seedJob.getDuedate());
 assertNull(seedJob.getDeploymentId());
 assertNull(seedJob.getProcessDefinitionId());
 assertNull(seedJob.getProcessDefinitionKey());
 assertNull(seedJob.getProcessInstanceId());
 assertNull(seedJob.getExecutionId());
 // but no deletion jobs where created
 List<Job> deletionJobs = helper.getExecutionJobs(batch);
 assertEquals(0, deletionJobs.size());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment(resources = {
  "org/camunda/bpm/engine/test/bpmn/event/signal/SignalEventTest.signalStartEvent.bpmn20.xml",
  "org/camunda/bpm/engine/test/bpmn/event/signal/SignalEventTests.throwAlertSignalAsync.bpmn20.xml"})
@Test
public void testAsyncSignalStartEventJobPropertiesDueDateSet() {
 Date testTime = new Date(1457326800000L);
 ClockUtil.setCurrentTime(testTime);
 processEngineConfiguration.setEnsureJobDueDateNotNull(true);
 ProcessDefinition catchingProcessDefinition = repositoryService
   .createProcessDefinitionQuery()
   .processDefinitionKey("startBySignal")
   .singleResult();
 // given a process instance that throws a signal asynchronously
 runtimeService.startProcessInstanceByKey("throwSignalAsync");
 // where the throwing instance ends immediately
 // then there is not yet a catching process instance
 assertEquals(0, runtimeService.createProcessInstanceQuery().count());
 // but there is a job for the asynchronous continuation
 Job asyncJob = managementService.createJobQuery().singleResult();
 assertEquals(catchingProcessDefinition.getId(), asyncJob.getProcessDefinitionId());
 assertEquals(catchingProcessDefinition.getKey(), asyncJob.getProcessDefinitionKey());
 assertNull(asyncJob.getExceptionMessage());
 assertNull(asyncJob.getExecutionId());
 assertNull(asyncJob.getJobDefinitionId());
 assertEquals(0, asyncJob.getPriority());
 assertNull(asyncJob.getProcessInstanceId());
 assertEquals(3, asyncJob.getRetries());
 assertEquals(testTime, asyncJob.getDuedate());
 assertNull(asyncJob.getDeploymentId());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment(resources = PARALLEL_GATEWAY_PROCESS)
public void testTheDeploymentIdIsSet() {
 ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("parallelGateway");
 String processDefinitionId = processInstance.getProcessDefinitionId();
 ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(processDefinitionId).singleResult();
 ActivityInstance tree = runtimeService.getActivityInstance(processInstance.getId());
 Batch modificationBatch = runtimeService
   .createProcessInstanceModification(processInstance.getId())
   .cancelActivityInstance(getInstanceIdForActivity(tree, "task1"))
   .executeAsync();
 assertNotNull(modificationBatch);
 Job job = managementService.createJobQuery().jobDefinitionId(modificationBatch.getSeedJobDefinitionId()).singleResult();
 // seed job
 managementService.executeJob(job.getId());
 for (Job pending : managementService.createJobQuery().jobDefinitionId(modificationBatch.getBatchJobDefinitionId()).list()) {
  managementService.executeJob(pending.getId());
  assertEquals(processDefinition.getDeploymentId(), pending.getDeploymentId());
 }
}

代码示例来源:origin: camunda/camunda-bpm-platform

public void assertJobMigrated(Job jobBefore, String activityIdAfter, Date dueDateAfter) {
 Job jobAfter = snapshotAfterMigration.getJobById(jobBefore.getId());
 assertNotNull("Expected that a job with id '" + jobBefore.getId() + "' exists after migration", jobAfter);
 JobDefinition jobDefinitionAfter = snapshotAfterMigration.getJobDefinitionForActivityIdAndType(activityIdAfter, ((JobEntity) jobBefore).getJobHandlerType());
 assertNotNull("Expected that a job definition for activity '" + activityIdAfter + "' exists after migration", jobDefinitionAfter);
 assertEquals(jobBefore.getId(), jobAfter.getId());
 assertEquals("Expected that job is assigned to job definition '" + jobDefinitionAfter.getId() + "' after migration",
   jobDefinitionAfter.getId(), jobAfter.getJobDefinitionId());
 assertEquals("Expected that job is assigned to deployment '" + snapshotAfterMigration.getDeploymentId() + "' after migration",
   snapshotAfterMigration.getDeploymentId(), jobAfter.getDeploymentId());
 assertEquals(dueDateAfter, jobAfter.getDuedate());
 assertEquals(((JobEntity) jobBefore).getType(), ((JobEntity) jobAfter).getType());
 assertEquals(jobBefore.getPriority(), jobAfter.getPriority());
 assertEquals(jobDefinitionAfter.getProcessDefinitionId(), jobAfter.getProcessDefinitionId());
 assertEquals(jobDefinitionAfter.getProcessDefinitionKey(), jobAfter.getProcessDefinitionKey());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment(resources = {
 "org/camunda/bpm/engine/test/bpmn/event/signal/SignalEventTest.signalStartEvent.bpmn20.xml",
 "org/camunda/bpm/engine/test/bpmn/event/signal/SignalEventTests.throwAlertSignalAsync.bpmn20.xml"})
@Test
public void testAsyncSignalStartEventJobProperties() {
 processEngineConfiguration.setEnsureJobDueDateNotNull(false);
 ProcessDefinition catchingProcessDefinition = repositoryService
  .createProcessDefinitionQuery()
  .processDefinitionKey("startBySignal")
  .singleResult();
 // given a process instance that throws a signal asynchronously
 runtimeService.startProcessInstanceByKey("throwSignalAsync");
 // where the throwing instance ends immediately
 // then there is not yet a catching process instance
 assertEquals(0, runtimeService.createProcessInstanceQuery().count());
 // but there is a job for the asynchronous continuation
 Job asyncJob = managementService.createJobQuery().singleResult();
 assertEquals(catchingProcessDefinition.getId(), asyncJob.getProcessDefinitionId());
 assertEquals(catchingProcessDefinition.getKey(), asyncJob.getProcessDefinitionKey());
 assertNull(asyncJob.getExceptionMessage());
 assertNull(asyncJob.getExecutionId());
 assertNull(asyncJob.getJobDefinitionId());
 assertEquals(0, asyncJob.getPriority());
 assertNull(asyncJob.getProcessInstanceId());
 assertEquals(3, asyncJob.getRetries());
 assertNull(asyncJob.getDuedate());
 assertNull(asyncJob.getDeploymentId());
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Deployment(resources = TEST_PROCESS_ONE_JOB)
public void testSetProcessDefinitionVersionMigrateJob() {
 // given a process instance
 ProcessInstance instance = runtimeService.startProcessInstanceByKey("oneJobProcess");
 // with a job
 Job job = managementService.createJobQuery().singleResult();
 assertNotNull(job);
 // and a second deployment of the process
 org.camunda.bpm.engine.repository.Deployment deployment = repositoryService
  .createDeployment()
  .addClasspathResource(TEST_PROCESS_ONE_JOB)
  .deploy();
 ProcessDefinition newDefinition =
   repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
 assertNotNull(newDefinition);
 // when the process instance is migrated
 CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutorTxRequired();
 commandExecutor.execute(new SetProcessDefinitionVersionCmd(instance.getId(), 2));
 // then the the job should also be migrated
 Job migratedJob = managementService.createJobQuery().singleResult();
 assertNotNull(migratedJob);
 assertEquals(job.getId(), migratedJob.getId());
 assertEquals(newDefinition.getId(), migratedJob.getProcessDefinitionId());
 assertEquals(deployment.getId(), migratedJob.getDeploymentId());
 JobDefinition newJobDefinition = managementService
   .createJobDefinitionQuery().processDefinitionId(newDefinition.getId()).singleResult();
 assertNotNull(newJobDefinition);
 assertEquals(newJobDefinition.getId(), migratedJob.getJobDefinitionId());
 repositoryService.deleteDeployment(deployment.getId(), true);
}

代码示例来源:origin: camunda/camunda-bpm-platform

assertEquals(job.getProcessDefinitionId(), historicJob.getProcessDefinitionId());
assertEquals(job.getProcessDefinitionKey(), historicJob.getProcessDefinitionKey());
assertEquals(job.getDeploymentId(), historicJob.getDeploymentId());
assertEquals(job.getPriority(), historicJob.getJobPriority());

代码示例来源:origin: camunda/camunda-bpm-platform

assertEquals(processDefinition.getDeploymentId(), pending.getDeploymentId());
assertEquals(TENANT_ONE, pending.getTenantId());

代码示例来源:origin: camunda/camunda-bpm-platform

assertEquals(job.getProcessDefinitionId(), historicJob.getProcessDefinitionId());
assertEquals(job.getProcessDefinitionKey(), historicJob.getProcessDefinitionKey());
assertEquals(job.getDeploymentId(), historicJob.getDeploymentId());
assertEquals(job.getPriority(), historicJob.getJobPriority());

代码示例来源:origin: camunda/camunda-bpm-platform

assertEquals(job.getProcessDefinitionId(), historicJob.getProcessDefinitionId());
assertEquals(job.getProcessDefinitionKey(), historicJob.getProcessDefinitionKey());
assertEquals(job.getDeploymentId(), historicJob.getDeploymentId());
assertEquals(job.getPriority(), historicJob.getJobPriority());

相关文章