Remove InputLoopService

Author: jasontaylordev

samples/aws/lambda-sqs/SQSLambda_3/RegularEndpoint/InputLoopService.cs

@@ -1,22 +1,54 @@
 using System;
+using System.Threading;
+using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using NServiceBus;
 
 Console.Title = "RegularEndpoint";
 
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
 
 var endpointConfiguration = new EndpointConfiguration("RegularEndpoint");
-
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.UseTransport<SqsTransport>();
 
-
 Console.WriteLine("Press any key, the application is starting");
 Console.ReadKey();
 Console.WriteLine("Starting...");
 
 builder.UseNServiceBus(endpointConfiguration);
-await builder.Build().RunAsync();
+
+var host = builder.Build();
+await host.StartAsync();
+
+// Get the required services
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+// Register a cancellation token to gracefully handle application shutdown
+var ct = host.Services.GetRequiredService<IHostApplicationLifetime>().ApplicationStopping;
+
+Console.WriteLine("Press [ENTER] to send a message to the serverless endpoint queue.");
+Console.WriteLine("Press Ctrl+C to shut down.");
+
+// Wait for user input to publish messages
+while (!ct.IsCancellationRequested)
+{
+    if (!Console.KeyAvailable)
+    {
+        // If no key is pressed, wait for a short time before checking again
+        await Task.Delay(100, CancellationToken.None);
+        continue;
+    }
+
+    var key = Console.ReadKey();
+    Console.WriteLine();
+
+    if (key.Key == ConsoleKey.Enter)
+    {
+        await messageSession.Send("ServerlessEndpoint", new TriggerMessage());
+        Console.WriteLine("Message sent to the serverless endpoint queue.");
+    }
+}
+
+// Wait for the host to stop gracefully
+await host.StopAsync();

samples/aws/lambda-sqs/SQSLambda_3/RegularEndpoint/Program.cs

@@ -4,7 +4,6 @@
 
 public class ResponseMessageHandler(ILogger<ResponseMessageHandler> logger) : IHandleMessages<ResponseMessage>
 {
-
     public Task Handle(ResponseMessage message, IMessageHandlerContext context)
     {
         logger.LogInformation("Handling {MessageType} in RegularEndpoint", nameof(ResponseMessage));