本文整理了Java中org.camunda.bpm.engine.runtime.Job.getDeploymentId()
方法的一些代码示例,展示了Job.getDeploymentId()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Job.getDeploymentId()
方法的具体详情如下:
包路径:org.camunda.bpm.engine.runtime.Job
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!