/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit.Abstractions/Transports/DictionarySendHeaderProvider.cs
29 строк
678 B
Chris Patterson
Added ExceptionHeaders to ExceptionReceiveContext so that additional transport headers can be specified (or existing headers replaced/removed) when moving messages to the error queue.
27 ноя 2024, 17:49
27 ноя 2024, 17:49
f8484cd
Код
Авторство
О чём код?
namespace MassTransit.Transports; using System.Collections.Generic; using System.Diagnostics.CodeAnalysis; /// <summary> /// A simple in-memory header collection for use with the in memory transport /// </summary> public class DictionarySendHeaderProvider : IHeaderProvider { readonly SendHeaders _headers; public DictionarySendHeaderProvider(SendHeaders headers) { _headers = headers; } public IEnumerable<KeyValuePair<string, object>> GetAll() { return _headers.GetAll(); } public bool TryGetHeader(string key, [NotNullWhen(true)] out object? value) { return _headers.TryGetHeader(key, out value); } }