refactored message service to process control queue