code: public void stop() {
          int notProcessed = worker.shutdownNow().size();
          if (notProcessed != 0) {
              LogFilter.log(LOGGER, LogLevel.INFO, "Worker exiting, {} execution events remaining, time: {}", notProcessed, System.currentTimeMillis());
          }
      }
docs: Shutdowns StatisticsQueue completely, new StatisticsQueue should be created to start gathering statistics again