SMP.Service/SMP.Message.Consumer/TaskRunner.cs

using SMP.Message.Consumer.MQConsumers;

namespace SMP.Message.Consumer
{
    internal class TaskRunner
    {
        public void Start()
        {
            ConsumeMQ();         
        }

        public void Stop() { }

        private void ConsumeMQ()
        {
            //消费成本利润报表消息
            MQManager.Subscribe(new CostProfitReportFileMessageConsumer());
            //导出文件任务
            MQManager.Subscribe(new ExportTaskMessageConsumer());
            //分摊任务
            MQManager.Subscribe(new SpreadTaskMessageConsumer());
        }
    }
}