in src/main/java/org/apache/sling/jobs/it/services/AsyncJobConsumer.java [114:121]
public void deactivate(Map<String, Object> properties) {
try {
executor.awaitTermination(shutdownWaitSeconds, TimeUnit.SECONDS);
} catch (InterruptedException e) {
LOGGER.error("Interrupted while waiting for queue to drain ",e);
}
executor.shutdown();
}