9293949596979899100101102
// Sleep for a while after starting server to let it init Thread.sleep(bufferMS); log.info("Producing data"); produce.start(); // Sleep for a while before shutting down server to let it finish Thread.sleep(bufferMS); } finally {
9596979899100101102103104105
Thread.sleep(bufferMS); // Load all updates first log.info("Producing updates"); updateProducer.start(); // Sleep for a while after starting server to let it init Thread.sleep(bufferMS); log.info("Producing input");