}
}
initTimestamp += intervalSec;
}
} else {
executor.submit(new StackExchangeStreamer(initTimestamp, initTimestamp + intervalSec));
while (true) {
try {
Thread.sleep(intervalSec);
} catch (InterruptedException e) {
LOGGER.error("sudden interrupt", e);
}
initTimestamp += intervalSec;
executor.submit(new StackExchangeStreamer(initTimestamp, initTimestamp + intervalSec));
}
}
}