public void deactivate()

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();
    }