using RabbitMQ.Client;

namespace Dpz.Core.MessageQueue.Abstractions;

/// <summary>
/// RabbitMQ连接工厂接口
/// </summary>
public interface IRabbitMQConnectionFactory : IAsyncDisposable
{
    /// <summary>
    /// 获取或创建连接
    /// </summary>
    Task<IConnection> GetConnectionAsync();

    /// <summary>
    /// 创建新的Channel
    /// </summary>
    Task<IChannel> CreateChannelAsync();
}