/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Consumers/Batching/MessageBatch.cs
42 строки
1 KB
Chris Patterson
Added MessageBatch<T> to the known serialization types so that it can be properly serialized without a proxy.
15 мар 2022, 23:49
15 мар 2022, 23:49
c91b774
Код
Авторство
О чём код?
namespace MassTransit.Batching { using System; using System.Collections; using System.Collections.Generic; [Serializable] public class MessageBatch<TMessage> : Batch<TMessage> where TMessage : class { readonly IReadOnlyList<ConsumeContext<TMessage>> _messages; public MessageBatch(DateTime firstMessageReceived, DateTime lastMessageReceived, BatchCompletionMode mode, IReadOnlyList<ConsumeContext<TMessage>> messages) { FirstMessageReceived = firstMessageReceived; LastMessageReceived = lastMessageReceived; Mode = mode; _messages = messages; } public BatchCompletionMode Mode { get; set; } public DateTime FirstMessageReceived { get; set; } public DateTime LastMessageReceived { get; set; } public ConsumeContext<TMessage> this[int index] => _messages[index]; public int Length => _messages.Count; public IEnumerator<ConsumeContext<TMessage>> GetEnumerator() { return _messages.GetEnumerator(); } IEnumerator IEnumerable.GetEnumerator() { return GetEnumerator(); } } }