QueuedOutboundMessage.cs

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

using Dreamine.Communication.Abstractions.Models;
 
namespace Dreamine.Communication.Core.Queues;

public sealed class QueuedOutboundMessage
{
    public QueuedOutboundMessage(MessageEnvelope message)
        : this(message, DateTimeOffset.UtcNow, 0, null)
    {
    }

    public QueuedOutboundMessage(
        MessageEnvelope message,
        DateTimeOffset enqueuedAt,
        int attemptCount,
        string? lastError)
    {
        Message = message ?? throw new ArgumentNullException(nameof(message));
        EnqueuedAt = enqueuedAt;
        AttemptCount = attemptCount;
        LastError = lastError;
    }

    public MessageEnvelope Message { get; }

    public DateTimeOffset EnqueuedAt { get; }

    public int AttemptCount { get; }

    public string? LastError { get; }

    public bool IsExpired(TimeSpan? maxAge, DateTimeOffset now)
    {
        if (maxAge is null)
        {
            return false;
        }
 
        return now - EnqueuedAt > maxAge.Value;
    }

    public QueuedOutboundMessage WithFailure(Exception exception)
    {
        ArgumentNullException.ThrowIfNull(exception);
 
        return new QueuedOutboundMessage(
            Message,
            EnqueuedAt,
            AttemptCount + 1,
            exception.Message);
    }
}