/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Clients/BusClientFactoryContext.cs
53 строки
2 KB
Chris Patterson
Fixed #3830 - Request Endpoints should always be from the bus, and not the ConsumeContext, since we might be jumping the tracks.
11 ноя 2022, 02:49
11 ноя 2022, 02:49
c37a7c5
Код
Авторство
О чём код?
#nullable enable namespace MassTransit.Clients { using System; public class BusClientFactoryContext : ClientFactoryContext { readonly IBus _bus; public BusClientFactoryContext(IBus bus, RequestTimeout defaultTimeout = default) { _bus = bus; DefaultTimeout = defaultTimeout.HasValue ? defaultTimeout : RequestTimeout.Default; } public ConnectHandle ConnectConsumePipe<T>(IPipe<ConsumeContext<T>> pipe) where T : class { return _bus.ConnectConsumePipe(pipe); } public ConnectHandle ConnectConsumePipe<T>(IPipe<ConsumeContext<T>> pipe, ConnectPipeOptions options) where T : class { return _bus.ConnectConsumePipe(pipe, options); } public ConnectHandle ConnectRequestPipe<T>(Guid requestId, IPipe<ConsumeContext<T>> pipe) where T : class { return _bus.ConnectRequestPipe(requestId, pipe); } public Uri ResponseAddress => _bus.Address; public IRequestSendEndpoint<T> GetRequestEndpoint<T>(ConsumeContext? consumeContext = default) where T : class { return new PublishRequestSendEndpoint<T>(_bus, consumeContext); } public IRequestSendEndpoint<T> GetRequestEndpoint<T>(Uri destinationAddress, ConsumeContext? consumeContext = default) where T : class { return new SendRequestSendEndpoint<T>(_bus, destinationAddress, consumeContext); } public RequestTimeout DefaultTimeout { get; } } }