using EasyNetQ;
/********************************************************************************

** auth： DBS

** date： 2018/11/14 22:08:05

** desc： 尚未编写描述

** Ver.:  V1.0.0

*********************************************************************************/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.WMS.Common.RabbitMQ
{
    public class MQHelper
    {
        static IBus inBus = null;
        static IBus outBus = null;
        /// <summary>
        /// 发送消息
        /// </summary>
        public static void Publish(Message msg)
        {
            //// 创建消息bus
            if (inBus == null || !inBus.IsConnected)
                inBus = BusBuilder.CreateMessageBus();
            try
            {
                inBus.Publish(msg, x => x.WithTopic(msg.MessageRouter));
            }
            catch (EasyNetQException ex)
            {
                //处理连接消息服务器异常 
            }

            //bus.Dispose();//与数据库connection类似，使用后记得销毁bus对象
        }

        /// <summary>
        /// 接收消息
        /// </summary>
        /// <param name="msg"></param>
        public static void Subscribe(Message msg, IProcessMessage ipro)
        {
            //// 创建消息bus
            if (outBus == null || !outBus.IsConnected)
               outBus= BusBuilder.CreateMessageBus();
            
            try
            {
                outBus.Subscribe<Message>(msg.MessageRouter, message => ipro.ProcessMsg(message), x => x.WithTopic(msg.MessageRouter));
            }
            catch (EasyNetQException ex)
            {
                //处理连接消息服务器异常 
            }
        }
    }
}