IRabbitMqChannel.cs

이 파일의 문서화 페이지로 가기

namespace Dreamine.Communication.RabbitMQ.Infrastructure;

public interface IRabbitMqChannel : IDisposable
{
    bool IsOpen { get; }

    void ExchangeDeclare(
        string exchange,
        string type,
        bool durable,
        bool autoDelete);

    void QueueDeclare(
        string queue,
        bool durable,
        bool exclusive,
        bool autoDelete);

    void QueueBind(
        string queue,
        string exchange,
        string routingKey);

    IRabbitMqBasicProperties CreateBasicProperties();

    void BasicPublish(
        string exchange,
        string routingKey,
        bool mandatory,
        IRabbitMqBasicProperties properties,
        ReadOnlyMemory<byte> body);

    string BasicConsume(
        string queue,
        bool autoAck,
        Func<RabbitMqDelivery, CancellationToken, Task> onReceived);

    void BasicAck(ulong deliveryTag, bool multiple);

    void BasicNack(ulong deliveryTag, bool multiple, bool requeue);

    void BasicReject(ulong deliveryTag, bool requeue);

    void BasicCancel(string consumerTag);

    void Close();
}