saga self verification

Particular · May 31, 2024 · f23b1f3 · f23b1f3
1 parent d6f9a0c
commit f23b1f3
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/src/NServiceBus.AcceptanceTests/Core/OpenTelemetry/When_incoming_message_was_delayed.cs b/src/NServiceBus.AcceptanceTests/Core/OpenTelemetry/When_incoming_message_was_delayed.cs
@@ -84,7 +84,7 @@ public async Task By_retry_Should_create_new_trace_and_link_to_send()
     public async Task By_saga_timeout_Should_create_new_trace_and_link_to_send()
     {
         var context = await Scenario.Define<SagaContext>()
-            .WithEndpoint<SagaEndpoint>(b => b
+            .WithEndpoint<SagaOtelEndpoint>(b => b
                 .When(s => s.SendLocal(new StartSagaMessage { SomeId = Guid.NewGuid().ToString() })))
             .Done(c => c.SagaMarkedComplete)
             .Run();
@@ -181,9 +181,9 @@ public Task Handle(ReplyMessage message, IMessageHandlerContext context)
         }
     }
 
-    class SagaEndpoint : EndpointConfigurationBuilder
+    class SagaOtelEndpoint : EndpointConfigurationBuilder
     {
-        public SagaEndpoint()
+        public SagaOtelEndpoint()
         {
             var template = new DefaultServer
             {
@@ -199,11 +199,11 @@ public SagaEndpoint()
                 }, metadata => { });
         }
 
-        public class Saga : Saga<MySagaData>, IAmStartedByMessages<StartSagaMessage>, IHandleTimeouts<TimeoutMessage>, IHandleMessages<CompleteSagaMessage>
+        public class OtelSaga : Saga<MyOtelSagaData>, IAmStartedByMessages<StartSagaMessage>, IHandleTimeouts<TimeoutMessage>, IHandleMessages<CompleteSagaMessage>
         {
             SagaContext testContext;
 
-            public Saga(SagaContext testContext) => this.testContext = testContext;
+            public OtelSaga(SagaContext testContext) => this.testContext = testContext;
 
             public Task Handle(StartSagaMessage message, IMessageHandlerContext context)
             {
@@ -212,7 +212,7 @@ public Task Handle(StartSagaMessage message, IMessageHandlerContext context)
                 return RequestTimeout<TimeoutMessage>(context, DateTimeOffset.UtcNow.AddMilliseconds(2));
             }
 
-            protected override void ConfigureHowToFindSaga(SagaPropertyMapper<MySagaData> mapper)
+            protected override void ConfigureHowToFindSaga(SagaPropertyMapper<MyOtelSagaData> mapper)
             {
                 mapper.ConfigureMapping<StartSagaMessage>(m => m.SomeId).ToSaga(s => s.SomeId);
                 mapper.ConfigureMapping<CompleteSagaMessage>(m => m.SomeId).ToSaga(s => s.SomeId);
@@ -230,9 +230,9 @@ public Task Handle(CompleteSagaMessage message, IMessageHandlerContext context)
                 return Task.CompletedTask;
             }
         }
-        public class MySagaData : ContainSagaData
+        public class MyOtelSagaData : ContainSagaData
         {
-            public string SomeId { get; set; }
+            public virtual string SomeId { get; set; }
         }
     }