Removed used of EndpointConvention

matei-tm · Apr 21, 2022 · 6d774db · 6d774db
1 parent 9886c9b
commit 6d774db
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 7 deletions.
diff --git a/src/SampleBatch.Components/StateMachines/BatchJobStateMachine.cs b/src/SampleBatch.Components/StateMachines/BatchJobStateMachine.cs
@@ -21,7 +21,7 @@ public BatchJobStateMachine()
                     .Then(context => Touch(context.Saga, context.Message.Timestamp))
                     .Then(context => SetReceiveTimestamp(context.Saga, context.Message.Timestamp))
                     .Then(Initialize)
-                    .Send(context => context.Init<ProcessBatchJob>(new
+                    .PublishAsync(context => context.Init<ProcessBatchJob>(new
                     {
                         BatchJobId = context.Saga.CorrelationId,
                         InVar.Timestamp,

diff --git a/src/SampleBatch.Service/Program.cs b/src/SampleBatch.Service/Program.cs
@@ -83,9 +83,6 @@ static async Task Main(string[] args)
                             {
                                 y.Host(appConfig.AzureServiceBus.ConnectionString);
 
-                                var endpointNameFormatter = x.GetRequiredService<IEndpointNameFormatter>();
-                                EndpointConvention.Map<ProcessBatchJob>(new Uri($"queue:{endpointNameFormatter.Consumer<ProcessBatchJobConsumer>()}"));
-
                                 y.UseServiceBusMessageScheduler();
 
                                 y.ConfigureEndpoints(x);
@@ -101,9 +98,6 @@ static async Task Main(string[] args)
                                     h.Password(appConfig.RabbitMq.Password);
                                 });
 
-                                var endpointNameFormatter = x.GetRequiredService<IEndpointNameFormatter>();
-                                EndpointConvention.Map<ProcessBatchJob>(new Uri($"queue:{endpointNameFormatter.Consumer<ProcessBatchJobConsumer>()}"));
-
                                 y.UseInMemoryScheduler();
 
                                 y.ConfigureEndpoints(x);