void () { LOG.debug("analyzer started"); myAnalyzerQueue.activate(); myResultsUpdateQueue.activate(); myAnalyzerQueue.queue(new Update("reset") { @Override public void run() { myStopped.set(false); } }); }