import com.google.common.base.Optional;
import java.io.Closeable;
-import java.io.IOException;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
}
@Override
- public void close() throws IOException {
+ public void close() {
executor.shutdown();
}