/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
tests/MassTransit.Abstractions.Tests/Usage/ProcessOrderActivity.cs
45 строк
1 KB
Chris Patterson
Removed Obsolete Property, added a bunch of obsolete attributes
10 авг 2023, 06:43
10 авг 2023, 06:43
15c44ca
Код
Авторство
О чём код?
namespace MassTransit.Abstractions.Tests.Usage { using System; using System.Threading.Tasks; public class ProcessOrderActivity : IActivity<ProcessOrderArguments, ProcessOrderLog> { public async Task<ExecutionResult> Execute(ExecuteContext<ProcessOrderArguments> context) { Guid shipmentId = NewId.NextGuid(); return context.Completed<ProcessOrderLog>(new { shipmentId }); } public async Task<CompensationResult> Compensate(CompensateContext<ProcessOrderLog> context) { return context.Compensated(); } } public class ProcessOrderActivityDefinition : ActivityDefinition<ProcessOrderActivity, ProcessOrderArguments, ProcessOrderLog> { public ProcessOrderActivityDefinition() { ExecuteEndpoint(x => x.PrefetchCount = 16); CompensateEndpoint(x => x.PrefetchCount = 4); } protected override void ConfigureExecuteActivity(IReceiveEndpointConfigurator endpointConfigurator, IExecuteActivityConfigurator<ProcessOrderActivity, ProcessOrderArguments> executeActivityConfigurator, IRegistrationContext context) { } protected override void ConfigureCompensateActivity(IReceiveEndpointConfigurator endpointConfigurator, ICompensateActivityConfigurator<ProcessOrderActivity, ProcessOrderLog> compensateActivityConfigurator, IRegistrationContext context) { } } }