src/Library/NetPro.RabbitMQ/Configuration/RabbitMqExchangeOptions.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using RabbitMQ.Client;
using System;
using System.Collections.Generic;

namespace MQMiddleware.Configuration
{
    /// <summary>
    /// Exchange options.
    /// </summary>
    public class RabbitMqExchangeOptions
    {
        /// <summary>
        /// Exchange type.
        /// direct;fanout ;topic 
        /// </summary>
        public string Type { get; set; } = ExchangeType.Direct;

        /// <summary>
        /// Durable option.
        /// </summary>
        public bool Durable { get; set; } = true;

        /// <summary>
        /// AutoDelete option.
        /// </summary>
        public bool AutoDelete { get; set; }

        /// <summary>
        /// Default dead-letter-exchange.
        /// </summary>
        public string DeadLetterExchange { get; set; } = " ";

        /// <summary>
        /// Option to re-queue failed messages (once).
        /// </summary>
        [Obsolete("Change the attribute has been enabled, please use ConsumeFailedAction")]
        public bool RequeueFailedMessages { get; set; } = true;

        /// <summary>
        /// ConsumeAction Level
        /// </summary>
        public ConsumeFailedAction ConsumeFailedAction { get; set; } = ConsumeFailedAction.RETRY_ONCE;

        /// <summary>
        /// Additional arguments.
        /// </summary>
        public IDictionary<string, object> Arguments { get; set; } = new Dictionary<string, object>();

        /// <summary>
        /// Collection of queues connected to the exchange.
        /// </summary>
        public IList<RabbitMqQueueOptions> Queues { get; set; } = new List<RabbitMqQueueOptions>();
    }

    /// <summary>
    /// ConsumeFailedAction Level
    /// </summary>
    public enum ConsumeFailedAction
    {
        /// <summary>