![]() ![]() g_Create | 0 > d.MoveNext()Īt .EntityFrameworkSagaRepositor圜ontextFactory`1.WithinTransaction(DbContext context, CancellationToken cancellationToken, Func`1 callback)Īt .EntityFrameworkSagaRepositor圜ontextFactory`1.Send(ConsumeContext`1 context, IPipe`1 next)Īt 圜ontextFactory`1. End of stack trace from previous location -Īt .EntityFrameworkSagaRepositor圜ontextFactory`1. System.ArgumentException: THe message could not be retrieved: IInitialSagaEvent(Parameter 'context')Īt .SagaMergePipe`2.Send(SagaConsumeContext`1 context)Īt `1.(TContext context, IPipe`1 next)Īt `2.Send(SagaRepositor圜ontext`2 context)Īt .EntityFrameworkSagaRepositor圜ontextFactory`1. Static string connectionString = string.Empty Private static async Task RunPoc(IServiceProvider serviceProvider) Var busControl = serviceProvider.GetRequiredService() Var serviceProvider = services.BuildServiceProvider() R.ConcurrencyMode = ConcurrencyMode.Optimistic ĬonfigureMassTransit.SetEndpointNameFormatter(new DefaultEndpointNameFormatter(true)) ĬonfigureMassTransit.UsingActiveMq((context, config) =>Ĭonfig.Host("artemis", 61616, configureHost => Services.AddMassTransit(configureMassTransit =>ĬonfigureMassTransit.AddSagaStateMachine() M.MigrationsHistoryTable($"_EFMigrationsHistory_Sagas") M.MigrationsAssembly(typeof(MySagaDbContext).Assembly.GetName().Name) => builder.UseSqlServer(connectionString, m => ![]() Services.AddDbContext((provider, builder) Public static async Task Main(string args) R.Interval(5, TimeSpan.FromMilliseconds(100)) ![]() R.Handle(y => y.InnerException is SqlException e & e.Number = 2627) This is the SQLServer error code for duplicate key Protected override void ConfigureConsumer(IReceiveEndpointConfigurator endpointConfigurator, IConsumerConfigurator consumerConfigurator) => Public class ExternalCheckRequestConsumerDefinition : ConsumerDefinition Protected override void Configure(EntityTypeBuilder entity, ModelBuilder model)Įntity.Property(x => x.CurrentState).HasMaxLength(128) Įntity.Property(x => x.RowVersion).IsRowVersion() Public class MySagaClassMap : SagaClassMap Protected override IEnumerable Configurations Public interface IInitialSagaEvent : CorrelatedBy ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |