基於EasyNetQ的RabbitMQ封裝類

最近在搗鼓RabbitMQ，為了方便使用，自己基於EasyNetQ封裝了一個類，現在貼出來還望各路大佬神明指點，共同學習。

    /// <summary>
    /// RabbitMQ客戶端封裝類，基於EasyNetQ，使用時需要從nuget安裝EasyNetQ。
    /// <para>
    /// <example>
    /// 使用方法：
    /// <code>
    /// using(var mq = new RabbitMqClient('rabbitmq連接字符串'))
    /// { ...
    /// }
    /// </code>
    /// </example>
    /// </para>
    /// </summary>
    public class RabbitMqClient : IDisposable
    {
        private readonly IBus bus;

        /// <summary>
        /// 構造函數
        /// </summary>
        /// <param name="connectionString">rabbitmq連接字符串</param>
        public RabbitMqClient(string connectionString)
        {
            if (string.IsNullOrEmpty(connectionString))
                throw new ArgumentNullException(nameof(connectionString));
            bus = RabbitHutch.CreateBus(connectionString);
        }
        /// <summary>
        /// 發布一條消息(廣播)
        /// </summary>
        /// <param name="message"></param>
        public void Publish<TMessage>(TMessage message) where TMessage:class 
        {
            bus.PublishAsync(message);
        }

        /// <summary>
        /// 指定Topic，發布一條消息
        /// </summary>
        /// <param name="message"></param>
        /// <param name="topic"></param>
        public void PublishWithTopic<TMessage>(TMessage message, string topic) where TMessage : class
        {
            if(string.IsNullOrEmpty(topic))
                Publish(message);
            else
                bus.PublishAsync(message, x=>x.WithTopic(topic));
        }

        /// <summary>
        /// 發布消息。一次性發布多條
        /// </summary>
        /// <param name="messages"></param>
        public void PublishMany<TMessage>(List<TMessage> messages) where TMessage : class 
        {
            foreach (var message in messages)
            {
                Publish(message);
                Thread.Sleep(50);//必須加上，以防消息阻塞
            }
        }

        /// <summary>
        /// 發布消息。一次性發布多條
        /// </summary>
        /// <param name="messages"></param>
        /// <param name="topic"></param>
        public void PublishManyWithTopic<TMessage>(List<TMessage> messages, string topic) where TMessage : class
        {
            foreach (var message in messages)
            {
                PublishWithTopic(message, topic);
                Thread.Sleep(50);//必須加上，以防消息阻塞
            }
        }

        /// <summary>
        /// 給指定隊列發送一條信息
        /// </summary>
        /// <param name="queue">隊列名稱</param>
        /// <param name="message">消息</param>
        public void Send<TMessage>(string queue, TMessage message) where TMessage : class
        {
            bus.Send(queue, message);
        }

        /// <summary>
        /// 給指定隊列批量發送信息
        /// </summary>
        /// <param name="queue">隊列名稱</param>
        /// <param name="messages">消息</param>
        public void SendMany<TMessage>(string queue, IList<TMessage> messages) where TMessage : class
        {
            foreach (var message in messages)
            {
                SendAsync(queue, message);
                Thread.Sleep(50);//必須加上，以防消息阻塞
            }
        }

        /// <summary>
        /// 給指定隊列發送一條信息（異步）
        /// </summary>
        /// <param name="queue">隊列名稱</param>
        /// <param name="message">消息</param>
        /// <returns></returns>
        public async void SendAsync<TMessage>(string queue, TMessage message) where TMessage:class 
        {
            await bus.SendAsync(queue, message);
        }

        /// <summary>
        /// 從指定隊列接收一天信息，並做相關處理。
        /// </summary>
        /// <param name="queue">隊列名稱</param>
        /// <param name="process">
        /// 消息處理委托方法
        /// <para>
        /// <example>
        /// 例如：
        /// <code>
        /// message=>Task.Factory.StartNew(()=>{
        ///     Console.WriteLine(message);
        /// })
        /// </code>
        /// </example>
        /// </para>
        /// </param>
        public void Receive<TMessage>(string queue, Func<TMessage, Task> process) where TMessage:class 
        {
            bus.Receive(queue, process);
        }

        /// <summary>
        /// 消息訂閱
        /// </summary>
        /// <param name="subscriptionId">消息訂閱標識</param>
        /// <param name="process">
        /// 消息處理委托方法
        /// <para>
        /// <example>
        /// 例如：
        /// <code>
        /// message=>Task.Factory.StartNew(()=>{
        ///     Console.WriteLine(message);
        /// })
        /// </code>
        /// </example>
        /// </para>
        /// </param>
        public void Subscribe<TMessage>(string subscriptionId, Func<TMessage, Task> process) where TMessage:class 
        {
            bus.Subscribe<TMessage>(subscriptionId, message => process(message));
        }

        /// <summary>
        /// 消息訂閱
        /// </summary>
        /// <param name="subscriptionId">消息訂閱標識</param>
        /// <param name="process">
        /// 消息處理委托方法
        /// <para>
        /// <example>
        /// 例如：
        /// <code>
        /// message=>Task.Factory.StartNew(()=>{
        ///     Console.WriteLine(message);
        /// })
        /// </code>
        /// </example>
        /// </para>
        /// </param>
        /// <param name="topic">topic</param>
        public void SubscribeWithTopic<TMessage>(string subscriptionId, Func<TMessage, Task> process, string topic) where TMessage:class 
        {
            bus.Subscribe<TMessage>(subscriptionId, message => process(message), x=>x.WithTopic(topic));
        }

        /// <summary>
        /// 自動訂閱
        /// </summary>
        /// <param name="assemblyName"></param>
        /// <param name="subscriptionIdPrefix"></param>
        /// <param name="topic"></param>
        public void AutoSubscribe(string assemblyName, string subscriptionIdPrefix, string topic)
        {
            var subscriber = new AutoSubscriber(bus, subscriptionIdPrefix);
            if (!string.IsNullOrEmpty(topic))
                subscriber.ConfigureSubscriptionConfiguration = x => x.WithTopic(topic);
            subscriber.Subscribe(Assembly.Load(assemblyName));
        }

        /// <summary>
        /// 資源釋放
        /// </summary>
        public void Dispose()
        {
            if (bus != null) bus.Dispose();
        }
    }