6465666768697071727374
tailService.submit(new Runnable() { @Override public void run() { try { tailer.watch(); if (!shutdown) { LOG.info("Consuming tail: {}", tail); tailer.consumeStream();