Package org.activiti.engine.impl.asyncexecutor

Examples of org.activiti.engine.impl.asyncexecutor.AsyncExecutor.shutdown()

401
402
403
404
405
406
407
408
409
410
411
    } finally {
      if (processEngineConfiguration.isAsyncExecutorEnabled() == false) {
        jobExecutor.shutdown();
      } else {
        asyncExecutor.shutdown();
      }
    }
  }

  public void waitForJobExecutorOnCondition(long maxMillisToWait, long intervalMillis, Callable<Boolean> condition) {
View Full Code Here
442
443
444
445
446
447
448
449
450
451
452
    } finally {
      if (processEngineConfiguration.isAsyncExecutorEnabled() == false) {
        jobExecutor.shutdown();
      } else {
        asyncExecutor.shutdown();
      }
    }
  }

  public boolean areJobsAvailable() {
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
  private void moveByHours(int hours) throws Exception {
    processEngineConfiguration.getClock().setCurrentTime(new Date(processEngineConfiguration.getClock().getCurrentTime().getTime() + ((hours * 60 * 1000 * 60) + 5000)));
    AsyncExecutor asyncExecutor = processEngineConfiguration.getAsyncExecutor();
    asyncExecutor.start();
    Thread.sleep(1000);
    asyncExecutor.shutdown();
  }



}
View Full Code Here
240
241
242
243
244
245
246
247
248
249
250
    } finally {
      if (processEngineConfiguration.isAsyncExecutorEnabled() == false) {
        jobExecutor.shutdown();
      } else {
        asyncExecutor.shutdown();
      }
    }
  }

  public void waitForJobExecutorOnCondition(long maxMillisToWait, long intervalMillis, Callable<Boolean> condition) {
View Full Code Here
281
282
283
284
285
286
287
288
289
290
291
    } finally {
      if (processEngineConfiguration.isAsyncExecutorEnabled() == false) {
        jobExecutor.shutdown();
      } else {
        asyncExecutor.shutdown();
      }
    }
  }
 
  public void executeJobExecutorForTime(long maxMillisToWait, long intervalMillis) {
View Full Code Here
316
317
318
319
320
321
322
323
324
325
326
    } finally {
      if (processEngineConfiguration.isAsyncExecutorEnabled() == false) {
        jobExecutor.shutdown();
      } else {
        asyncExecutor.shutdown();
      }
    }
  }

  public boolean areJobsAvailable() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.