MessageEnvelopeExtensions.cs

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

using System.Text;
using Dreamine.Communication.Abstractions.Models;
 
namespace Dreamine.Communication.Core.Extensions;

public static class MessageEnvelopeExtensions
{
    public static string GetPayloadAsString(this MessageEnvelope message)
    {
        ArgumentNullException.ThrowIfNull(message);
        return Encoding.UTF8.GetString(message.Payload);
    }

    public static MessageEnvelope FromStringPayload(
        string route,
        string name,
        string payload)
    {
        ArgumentException.ThrowIfNullOrWhiteSpace(route);
        ArgumentException.ThrowIfNullOrWhiteSpace(name);
 
        return new MessageEnvelope
        {
            Route = route,
            Name = name,
            Payload = Encoding.UTF8.GetBytes(payload ?? string.Empty)
        };
    }
}