Fix incorrect use of InputLoopService in simple ASQ transport sample (#7441)

* Fix incorrect use of InputLoopService in simple ASQ transport sample

* Use correct Shared namespace for messages

Author: DavidBoike

samples/azure/storage-queues/ASQN_13/Endpoint1/Endpoint2ResponseHandler.cs

@@ -1,11 +1,12 @@
 using System.Threading.Tasks;
 using NServiceBus;
 using Microsoft.Extensions.Logging;
+using Shared;
 
 public sealed class Endpoint2ResponseHandler(ILogger<Endpoint2ResponseHandler> logger)
-    : IHandleMessages<Endpoint2.MyResponse>
+    : IHandleMessages<MyResponse>
 {
-    public Task Handle(Endpoint2.MyResponse message, IMessageHandlerContext context)
+    public Task Handle(MyResponse message, IMessageHandlerContext context)
     {
         logger.LogInformation("Received MyResponse: {Property}", message.Property);
         return Task.CompletedTask;

samples/azure/storage-queues/ASQN_13/Endpoint1/InputLoopService.cs

@@ -1,11 +1,10 @@
 using System;
-using Endpoint1;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using NServiceBus;
+using Shared;
 
 var host = Host.CreateDefaultBuilder(args)
-    .ConfigureServices((hostContext, services) => { services.AddHostedService<InputLoopService>(); })
     .UseNServiceBus(x =>
     {
         #region endpointName
@@ -21,7 +20,7 @@
 
         var transport = new AzureStorageQueueTransport("UseDevelopmentStorage=true");
         var routingSettings = endpointConfiguration.UseTransport(transport);
-        routingSettings.RouteToEndpoint(typeof(Endpoint2.MyRequest), "Samples-Azure-StorageQueues-Endpoint2");
+        routingSettings.RouteToEndpoint(typeof(MyRequest), "Samples-Azure-StorageQueues-Endpoint2");
 
         #endregion
 
@@ -39,4 +38,26 @@
         return endpointConfiguration;
     }).Build();
 
-await host.RunAsync();
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+Console.WriteLine("Press 'enter' to send a message");
+while (true)
+{
+    var key = Console.ReadKey();
+    Console.WriteLine();
+
+    if (key.Key != ConsoleKey.Enter)
+    {
+        break;
+    }
+
+    var message = new MyRequest("Hello from Endpoint1");
+
+    await messageSession.Send(message);
+
+    Console.WriteLine("MyRequest sent");
+}
+
+await host.StopAsync();

samples/azure/storage-queues/ASQN_13/Endpoint1/Program.cs

@@ -1,14 +1,15 @@
 using System.Threading.Tasks;
 using NServiceBus;
 using Microsoft.Extensions.Logging;
+using Shared;
 
 public sealed class MyRequestResponseHandler(ILogger<MyRequestResponseHandler> logger)
-    : IHandleMessages<Endpoint2.MyRequest>
+    : IHandleMessages<MyRequest>
 {
-    public Task Handle(Endpoint2.MyRequest message, IMessageHandlerContext context)
+    public Task Handle(MyRequest message, IMessageHandlerContext context)
     {
         logger.LogInformation("Received MyRequest: {Property}", message.Property);
-        var myResponse = new Endpoint2.MyResponse("Hello from Endpoint2");
+        var myResponse = new MyResponse("Hello from Endpoint2");
         return context.Reply(myResponse);
     }
 }

samples/azure/storage-queues/ASQN_13/Endpoint2/MyRequestResponseHandler.cs

@@ -1,5 +1,5 @@
 using NServiceBus;
 
-namespace Endpoint2;
+namespace Shared;
 
 public record MyRequest(string Property) : IMessage;

samples/azure/storage-queues/ASQN_13/Shared/MyRequest.cs

@@ -1,5 +1,5 @@
 using NServiceBus;
 
-namespace Endpoint2;
+namespace Shared;
 
 public record MyResponse(string Property) : IMessage;