IMessageBus.cs

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

using System;
using System.Threading;
using System.Threading.Tasks;
using Dreamine.Communication.Abstractions.Enums;
using Dreamine.Communication.Abstractions.Models;
 
namespace Dreamine.Communication.Abstractions.Interfaces;

public interface IMessageBus : IConnectionLifecycle, IAsyncDisposable
{
    TransportKind Kind { get; }

    Task PublishAsync(
        MessageEnvelope message,
        CancellationToken cancellationToken = default);

    Task SubscribeAsync(
        string route,
        Func<MessageEnvelope, CancellationToken, Task> handler,
        CancellationToken cancellationToken = default);
}