Added nsb10 sample (#7617)

Author: ngallegos

samples/azure/webjob-host/Core_10/Receiver/HostBuilderExtensions.cs

@@ -0,0 +1,66 @@
+using System;
+
+using System.Threading;
+using System.Threading.Tasks;
+
+using Microsoft.Azure.WebJobs;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+
+using NServiceBus;
+
+public static class HostBuilderExtensions
+{
+    public static IHostBuilder ConfigureHost(this IHostBuilder hostBuilder)
+    {
+        hostBuilder.ConfigureWebJobs(builder => builder.AddAzureStorageCoreServices());
+
+        hostBuilder.ConfigureLogging((context, builder) =>
+        {
+            builder.AddConsole();
+        });
+
+        #region WebJobHost_Start
+        hostBuilder.UseNServiceBus(ctx =>
+        {
+            var endpointConfiguration = new EndpointConfiguration("receiver");
+            endpointConfiguration.DefineCriticalErrorAction(OnCriticalError);
+            endpointConfiguration.UsePersistence<NonDurablePersistence>();
+            endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+            endpointConfiguration.EnableInstallers();
+
+            var transportConnectionString = ctx.Configuration.GetConnectionString("TransportConnectionString");
+            endpointConfiguration.UseTransport(new AzureStorageQueueTransport(transportConnectionString));
+
+            return endpointConfiguration;
+        });
+        #endregion
+
+        hostBuilder.ConfigureServices((context, services) =>
+        {
+            services.AddHostedService<SimulateWorkHostedService>();
+            services.AddSingleton<IJobHost, NoOpJobHost>();
+        });
+
+        return hostBuilder;
+    }
+
+    #region WebJobHost_CriticalError
+    static async Task OnCriticalError(ICriticalErrorContext context, CancellationToken cancellationToken)
+    {
+        var fatalMessage =
+            $"The following critical error was encountered:{Environment.NewLine}{context.Error}{Environment.NewLine}Process is shutting down. StackTrace: {Environment.NewLine}{context.Exception.StackTrace}";
+
+        try
+        {
+            await context.Stop(cancellationToken);
+        }
+        finally
+        {
+            Environment.FailFast(fatalMessage, context.Exception);
+        }
+    }
+    #endregion
+}

samples/azure/webjob-host/Core_10/Receiver/MyMessage.cs

@@ -0,0 +1,4 @@
+using NServiceBus;
+public class MyMessage : ICommand
+{
+}

samples/azure/webjob-host/Core_10/Receiver/MyMessageHandler.cs

@@ -0,0 +1,19 @@
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+public class MyMessageHandler : IHandleMessages<MyMessage>
+{
+    public MyMessageHandler(ILogger<MyMessageHandler> logger)
+    {
+        this.logger = logger;
+    }
+
+    public Task Handle(MyMessage message, IMessageHandlerContext context)
+    {
+        logger.LogInformation("Received message");
+        return Task.CompletedTask;
+    }
+
+    private readonly ILogger logger;
+}

samples/azure/webjob-host/Core_10/Receiver/NoOpJobHost.cs

@@ -0,0 +1,22 @@
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.Azure.WebJobs;
+
+public class NoOpJobHost : IJobHost
+{
+    public Task CallAsync(string name, IDictionary<string, object> arguments = null, CancellationToken cancellationToken = new CancellationToken())
+    {
+        throw new System.NotImplementedException();
+    }
+
+    public Task StartAsync(CancellationToken cancellationToken)
+    {
+        return Task.CompletedTask;
+    }
+
+    public Task StopAsync()
+    {
+        return Task.CompletedTask;
+    }
+}

samples/azure/webjob-host/Core_10/Receiver/Program.cs

@@ -0,0 +1,13 @@
+using Microsoft.Azure.WebJobs;
+using Microsoft.Extensions.Hosting;
+
+
+var host = Host.CreateDefaultBuilder()
+    .ConfigureHost()
+    .Build();
+
+var cancellationToken = new WebJobsShutdownWatcher().Token;
+using (host)
+{
+    await host.RunAsync(cancellationToken);
+}

samples/azure/webjob-host/Core_10/Receiver/Properties/launchSettings.json

@@ -0,0 +1,10 @@
+{
+  "profiles": {
+    "Receiver": {
+      "commandName": "Project",
+      "environmentVariables": {
+        "DOTNET_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

samples/azure/webjob-host/Core_10/Receiver/Receiver.csproj

@@ -0,0 +1,34 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <LangVersion>preview</LangVersion>
+    <TargetFramework>net10.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Azure.WebJobs" Version="3.*" />
+    <PackageReference Include="Microsoft.Azure.WebJobs.Host.Storage" Version="5.*" />
+    <PackageReference Include="NServiceBus" Version="10.0.0-alpha.2" />
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="4.0.0-alpha.2" />
+    <PackageReference Include="NServiceBus.Persistence.NonDurable" Version="3.0.0-alpha.2" />
+    <PackageReference Include="NServiceBus.Transport.AzureStorageQueues" Version="14.0.0-alpha.2" />
+  </ItemGroup>
+
+  <ItemGroup Label="Resolves vulnerabilities">
+    <PackageReference Include="Azure.Identity" Version="1.*" />
+    <PackageReference Include="Microsoft.Identity.Client" Version="4.*" />
+  </ItemGroup>
+
+  <ItemGroup Label="To disable Dashboard logging (https://docs.microsoft.com/en-us/azure/app-service/webjobs-sdk-get-started#enable-console-logging)">
+    <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="10.0.0-preview.6.25358.103" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <None Update="appsettings.development.json" CopyToOutputDirectory="PreserveNewest" />
+    <None Update="appsettings.json" CopyToOutputDirectory="PreserveNewest" />
+    <None Update="Settings.job" CopyToOutputDirectory="PreserveNewest" />
+    <None Update="run.cmd" CopyToOutputDirectory="PreserveNewest" />
+  </ItemGroup>
+
+</Project>

samples/azure/webjob-host/Core_10/Receiver/Settings.job

@@ -0,0 +1,3 @@
+{
+  "stopping_wait_time": 60
+}

samples/azure/webjob-host/Core_10/Receiver/SimulateWorkHostedService.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Hosting;
+using NServiceBus;
+
+class SimulateWorkHostedService : IHostedService
+{
+    public SimulateWorkHostedService(IMessageSession messageSession)
+    {
+        this.messageSession = messageSession;
+    }
+
+    public Task StartAsync(CancellationToken cancellationToken)
+    {
+        worker = SimulateWork(cancellationTokenSource.Token);
+        return Task.CompletedTask;
+    }
+
+    public Task StopAsync(CancellationToken cancellationToken)
+    {
+        cancellationTokenSource.Cancel();
+        return worker;
+    }
+
+    async Task SimulateWork(CancellationToken cancellationToken)
+    {
+        try
+        {
+            while (!cancellationToken.IsCancellationRequested)
+            {
+                // sending here to simulate work
+                await messageSession.SendLocal(new MyMessage(), cancellationToken: cancellationToken);
+
+                await Task.Delay(1000, cancellationToken);
+            }
+        }
+        catch (OperationCanceledException)
+        {
+            // graceful shutdown
+        }
+    }
+
+    readonly IMessageSession messageSession;
+    readonly CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
+    Task worker;
+}

samples/azure/webjob-host/Core_10/Receiver/appsettings.development.json

@@ -0,0 +1,13 @@
+{
+  "ConnectionStrings": {
+    "TransportConnectionString": "UseDevelopmentStorage=true"
+  },
+  "Logging": {
+    "Console": {
+      "LogLevel": {
+        "Default": "Information",
+        "Azure": "Warning"
+      }
+    }
+  }
+}