1130113111321133113411351136
} private void cleanDB() { String jobId = managementService.createJobQuery().singleResult().getId(); CommandExecutor commandExecutor = processEngineConfiguration.getCommandExecutorTxRequired(); commandExecutor.execute(new DeleteJobsCmd(jobId)); }
117118119120121122123124
} @Override protected void tearDown() throws Exception { repositoryService.deleteDeployment(deploymentId, true); commandExecutor.execute(new DeleteJobsCmd(messageId)); super.tearDown(); }
303304305306307308309310
.getCommandContext() .getJobManager() .findJobsByConfiguration(TimerStartEventJobHandler.TYPE, processDefinition.getKey()); for (Job job :jobsToDelete) { new DeleteJobsCmd(job.getId()).execute(Context.getCommandContext()); } }
158159160161162163164
AcquiredJobs acquiredJobs = getExecutableJobs(processEngineConfiguration.getJobExecutor()); Assert.assertEquals(1, acquiredJobs.size()); Assert.assertTrue(acquiredJobs.contains(messageId)); commandExecutor.execute(new DeleteJobsCmd(messageId)); }