Use FunctionsApplication.CreateBuilder

Author: bording

samples/azure-functions/service-bus-kafka/ASBS_4/AzureFunctions.KafkaTrigger.FunctionsHostBuilder/Program.cs

@@ -1,29 +1,28 @@
 using AzureFunctions.Messages.NServiceBusMessages;
+using Microsoft.Azure.Functions.Worker.Builder;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 
 #region SetupNServiceBusSendOnly
 
-var host = new HostBuilder()
-    .ConfigureServices(async services =>
-    {
-        var cfg = new EndpointConfiguration("SendOnly");
-        cfg.SendOnly();
-        cfg.UseSerialization<SystemJsonSerializer>();
+var builder = FunctionsApplication.CreateBuilder(args);
 
-        var connectionString = Environment.GetEnvironmentVariable("AzureWebJobsServiceBus");
-        var transport = new AzureServiceBusTransport(connectionString);
-        var routing = cfg.UseTransport(transport);
+var cfg = new EndpointConfiguration("SendOnly");
+cfg.SendOnly();
+cfg.UseSerialization<SystemJsonSerializer>();
 
-        routing.RouteToEndpoint(typeof(FollowUp), "Samples.KafkaTrigger.ConsoleEndpoint");
+var connectionString = Environment.GetEnvironmentVariable("AzureWebJobsServiceBus");
+var transport = new AzureServiceBusTransport(connectionString);
+var routing = cfg.UseTransport(transport);
 
-        var endpoint = await Endpoint.Start(cfg);
+routing.RouteToEndpoint(typeof(FollowUp), "Samples.KafkaTrigger.ConsoleEndpoint");
 
-        // Inject the endpoint in the DI container
-        services.AddSingleton<IMessageSession>(endpoint);
-    })
-    .ConfigureFunctionsWorkerDefaults()
-    .Build();
+var endpoint = await Endpoint.Start(cfg);
+
+// Inject the endpoint in the DI container
+builder.Services.AddSingleton<IMessageSession>(endpoint);
+
+var host = builder.Build();
 
 #endregion
 

samples/azure-functions/service-bus-kafka/ASBS_5/AzureFunctions.KafkaTrigger.FunctionsHostBuilder/Program.cs

@@ -1,29 +1,28 @@
 using AzureFunctions.Messages.NServiceBusMessages;
+using Microsoft.Azure.Functions.Worker.Builder;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 
 #region SetupNServiceBusSendOnly
 
-var host = new HostBuilder()
-    .ConfigureServices(async services =>
-    {
-        var cfg = new EndpointConfiguration("SendOnly");
-        cfg.SendOnly();
-        cfg.UseSerialization<SystemJsonSerializer>();
+var builder = FunctionsApplication.CreateBuilder(args);
 
-        var connectionString = Environment.GetEnvironmentVariable("AzureWebJobsServiceBus");
-        var transport = new AzureServiceBusTransport(connectionString, TopicTopology.Default);
-        var routing = cfg.UseTransport(transport);
+var cfg = new EndpointConfiguration("SendOnly");
+cfg.SendOnly();
+cfg.UseSerialization<SystemJsonSerializer>();
 
-        routing.RouteToEndpoint(typeof(FollowUp), "Samples.KafkaTrigger.ConsoleEndpoint");
+var connectionString = Environment.GetEnvironmentVariable("AzureWebJobsServiceBus");
+var transport = new AzureServiceBusTransport(connectionString, TopicTopology.Default);
+var routing = cfg.UseTransport(transport);
 
-        var endpoint = await Endpoint.Start(cfg);
+routing.RouteToEndpoint(typeof(FollowUp), "Samples.KafkaTrigger.ConsoleEndpoint");
 
-        // Inject the endpoint in the DI container
-        services.AddSingleton<IMessageSession>(endpoint);
-    })
-    .ConfigureFunctionsWorkerDefaults()
-    .Build();
+var endpoint = await Endpoint.Start(cfg);
+
+// Inject the endpoint in the DI container
+builder.Services.AddSingleton<IMessageSession>(endpoint);
+
+var host = builder.Build();
 
 #endregion
 

samples/azure-functions/service-bus-kafka/ASBS_6/AzureFunctions.KafkaTrigger.FunctionsHostBuilder/Program.cs

@@ -1,29 +1,28 @@
 using AzureFunctions.Messages.NServiceBusMessages;
+using Microsoft.Azure.Functions.Worker.Builder;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 
 #region SetupNServiceBusSendOnly
 
-var host = new HostBuilder()
-    .ConfigureServices(async services =>
-    {
-        var cfg = new EndpointConfiguration("SendOnly");
-        cfg.SendOnly();
-        cfg.UseSerialization<SystemJsonSerializer>();
+var builder = FunctionsApplication.CreateBuilder(args);
 
-        var connectionString = Environment.GetEnvironmentVariable("AzureWebJobsServiceBus");
-        var transport = new AzureServiceBusTransport(connectionString, TopicTopology.Default);
-        var routing = cfg.UseTransport(transport);
+var cfg = new EndpointConfiguration("SendOnly");
+cfg.SendOnly();
+cfg.UseSerialization<SystemJsonSerializer>();
 
-        routing.RouteToEndpoint(typeof(FollowUp), "Samples.KafkaTrigger.ConsoleEndpoint");
+var connectionString = Environment.GetEnvironmentVariable("AzureWebJobsServiceBus");
+var transport = new AzureServiceBusTransport(connectionString, TopicTopology.Default);
+var routing = cfg.UseTransport(transport);
 
-        var endpoint = await Endpoint.Start(cfg);
+routing.RouteToEndpoint(typeof(FollowUp), "Samples.KafkaTrigger.ConsoleEndpoint");
 
-        // Inject the endpoint in the DI container
-        services.AddSingleton<IMessageSession>(endpoint);
-    })
-    .ConfigureFunctionsWorkerDefaults()
-    .Build();
+var endpoint = await Endpoint.Start(cfg);
+
+// Inject the endpoint in the DI container
+builder.Services.AddSingleton<IMessageSession>(endpoint);
+
+var host = builder.Build();
 
 #endregion