STATION_COLLECT/mq/IRabbitmqService.cs

using AmrControl.Common;

namespace AmrControl.mq
{
    public interface IRabbitmqService
    {
        /// <summary>
        /// 初始化方法
        /// </summary>
        void Init();
        /// <summary>
        /// 发送消息
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="msg"></param>
        void SendMsg<T>(MqMessage<T> msg);
        /// <summary>
        /// 发送消息
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="topic"></param>
        /// <param name="msg"></param>
        void SendMsg<T>(string topic, MqMessage<T> msg);
    }
}