/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Clients/SendRequestSendEndpoint.cs
29 строк
847 B
Chris Patterson
Fixed #3832 (again) - this time, is more stain removing power (Azure Scheduled Message Cancel vs. Skip)
15 ноя 2022, 05:40
15 ноя 2022, 05:40
c0c761f
Код
Авторство
О чём код?
namespace MassTransit.Clients { using System; using System.Threading.Tasks; using Middleware; public class SendRequestSendEndpoint<TRequest> : RequestSendEndpoint<TRequest> where TRequest : class { readonly Uri _destinationAddress; readonly ISendEndpointProvider _provider; public SendRequestSendEndpoint(ISendEndpointProvider provider, Uri destinationAddress, ConsumeContext consumeContext) : base(consumeContext) { _provider = provider; _destinationAddress = destinationAddress; } protected override async Task<ISendEndpoint> GetSendEndpoint() { var endpoint = await _provider.GetSendEndpoint(_destinationAddress).ConfigureAwait(false); return endpoint.SkipOutbox(); } } }