Add running? method to worker, allowing subclasses to override its implementation for their own consumer shutdown criteria