Use shutdownNow instead to trigger InterruptedExceptions. The pull worker threads no longer hang indefinitely