Separate worker for consumer.
Bug fix.