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 ( ) ) ; } }
Shutdowns StatisticsQueue completely new StatisticsQueue should be created to start gathering statistics again