public synchronized void stop() throws ExecutionException, InterruptedException
{
if (!running)
- throw new RuntimeException("Consumier instance " + id + " is not running!");
+ throw new RuntimeException("Consumer instance " + id + " is not running!");
log.info("Stopping {}", id);
running = false;