/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit.Abstractions/Serialization/BytesMessageBody.cs
35 строк
646 B
Chris Patterson
Fixed #5692 - Reworked the interactions with connection/channel shutdown for RabbitMQ to run asynchronously
04 дек 2024, 01:13
04 дек 2024, 01:13
ceb3517
Код
Авторство
О чём код?
namespace MassTransit { using System.IO; using System.Text; public class BytesMessageBody : MessageBody { readonly byte[] _bytes; string? _string; public BytesMessageBody(byte[]? bytes) { _bytes = bytes ?? []; } public long? Length => _bytes.Length; public Stream GetStream() { return new MemoryStream(_bytes); } public byte[] GetBytes() { return _bytes; } public string GetString() { return _string ??= Encoding.UTF8.GetString(_bytes); } } }