RabbitMQ操作代码封装

1、Message.cs

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

namespace XFC.RabbitMQ.Domain
{
    /// <summary>
    /// 消息实体
    /// </summary>
    public class Message
    {
        /// <summary>
        /// 消息创建
        /// </summary>
        /// <param name="value">值</param>
        /// <param name="headers">头信息</param>
        /// <param name="contentType">MIME content type，缺省值为 text/plain</param>
        public Message(string value, IDictionary<string, object> headers, string contentType)
        {
            Value = value;
            Headers = headers;
            ContentType = contentType;
        }

        /// <summary>
        /// 消息创建
        /// </summary>
        /// <param name="value">值</param>
        /// <param name="headers">头信息</param>
        public Message(string value, IDictionary<string, object> headers)
            : this(value, headers, "text/plain")
        {
     
        }

        /// <summary>
        /// 消息创建
        /// </summary>
        /// <param name="value">值</param>
        /// <param name="contentType">MIME content type</param>
        public Message(string value, string contentType)
            : this(value, null, contentType)
        {

        }

        /// <summary>
        /// 消息创建
        /// </summary>
        /// <param name="value">值</param>
        public Message(string value)
            : this(value, null, "text/plain")
        {

        }

        /// <summary>
        /// 消息创建
        /// </summary>
        public Message()
            : this("", null, "text/plain")
        {

        }
        /// <summary>
        /// 消息值
        /// </summary>
        public string Value { get; set; }

        /// <summary>
        /// 消息头
        /// </summary>
        public IDictionary<string, object> Headers { get; set; }

        /// <summary>
        /// MIME content type
        /// </summary>
        public string ContentType { get; set; }
    }
}

View Code