Function manifests v2

src/IntegrationTest.Billing/BillingFunctions.cs

@@ -0,0 +1,37 @@
+namespace IntegrationTest.Billing;
+
+using Azure.Messaging.ServiceBus;
+using IntegrationTest.Shared;
+using Microsoft.Azure.Functions.Worker;
+
+// Pattern for multiple endpoints in one class with separate configs
+public partial class BillingFunctions
+{
+    [Function("BillingApi")]
+    [NServiceBusFunction]
+    public partial Task BillingApi(
+        [ServiceBusTrigger("billing-api", Connection = "AzureWebJobsServiceBus", AutoCompleteMessages = true)]
+        ServiceBusReceivedMessage message,
+        FunctionContext functionContext,
+        CancellationToken cancellationToken = default);
+
+    public static void ConfigureBillingApi(EndpointConfiguration configuration)
+    {
+        CommonEndpointConfig.Apply(configuration);
+        configuration.AddHandler<Handlers.ProcessPaymentHandler>();
+    }
+
+    [Function("BillingBackend")]
+    [NServiceBusFunction]
+    public partial Task BillingBackend(
+        [ServiceBusTrigger("billing-backend", Connection = "AzureWebJobsServiceBus", AutoCompleteMessages = true)]
+        ServiceBusReceivedMessage message,
+        FunctionContext functionContext,
+        CancellationToken cancellationToken = default);
+
+    public static void ConfigureBillingBackend(EndpointConfiguration configuration)
+    {
+        CommonEndpointConfig.Apply(configuration);
+        // different handlers for the backend queue
+    }
+}

src/IntegrationTest.Billing/Handlers/ProcessPaymentHandler.cs

@@ -0,0 +1,15 @@
+namespace IntegrationTest.Billing.Handlers;
+
+using IntegrationTest.Shared;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+public class ProcessPaymentHandler(ILogger<ProcessPaymentHandler> logger) : IHandleMessages<OrderSubmitted>
+{
+    public async Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+    {
+        logger.LogWarning($"Handling {nameof(OrderSubmitted)} in {nameof(ProcessPaymentHandler)}");
+
+        await context.Publish(new PaymentCleared()).ConfigureAwait(false);
+    }
+}

src/IntegrationTest.Billing/IntegrationTest.Billing.csproj

@@ -0,0 +1,23 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <InterceptorsPreviewNamespaces>$(InterceptorsPreviewNamespaces);NServiceBus</InterceptorsPreviewNamespaces>
+    <EmitCompilerGeneratedFiles>true</EmitCompilerGeneratedFiles>
+    <CompilerGeneratedFilesOutputPath>$(BaseIntermediateOutputPath)\GeneratedFiles</CompilerGeneratedFilesOutputPath>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.AzureServiceBus\NServiceBus.AzureFunctions.AzureServiceBus.csproj" />
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.Analyzer\NServiceBus.AzureFunctions.Analyzer.csproj"
+                      OutputItemType="Analyzer"
+                      ReferenceOutputAssembly="false" />
+    <ProjectReference Include="..\IntegrationTest.Shared\IntegrationTest.Shared.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="2.51.0" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.ServiceBus" Version="5.24.0" />
+  </ItemGroup>
+
+</Project>

src/IntegrationTest.Sales/Handlers/AcceptOrderHandler.cs

@@ -0,0 +1,15 @@
+namespace IntegrationTest.Sales.Handlers;
+
+using IntegrationTest.Shared;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+public class AcceptOrderHandler(ILogger<AcceptOrderHandler> logger) : IHandleMessages<SubmitOrder>
+{
+    public async Task Handle(SubmitOrder message, IMessageHandlerContext context)
+    {
+        logger.LogWarning($"Handling {nameof(SubmitOrder)} in {nameof(AcceptOrderHandler)}");
+
+        await context.Publish(new OrderSubmitted()).ConfigureAwait(false);
+    }
+}

src/IntegrationTest.Sales/IntegrationTest.Sales.csproj

@@ -0,0 +1,24 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <InterceptorsPreviewNamespaces>$(InterceptorsPreviewNamespaces);NServiceBus</InterceptorsPreviewNamespaces>
+    <EmitCompilerGeneratedFiles>true</EmitCompilerGeneratedFiles>
+    <CompilerGeneratedFilesOutputPath>$(BaseIntermediateOutputPath)\GeneratedFiles</CompilerGeneratedFilesOutputPath>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.AzureServiceBus\NServiceBus.AzureFunctions.AzureServiceBus.csproj" />
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.Analyzer\NServiceBus.AzureFunctions.Analyzer.csproj"
+                      OutputItemType="Analyzer"
+                      ReferenceOutputAssembly="false" />
+    <ProjectReference Include="..\IntegrationTest.Shared\IntegrationTest.Shared.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="2.51.0" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http" Version="3.3.0" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.ServiceBus" Version="5.24.0" />
+  </ItemGroup>
+
+</Project>

src/IntegrationTest.Sales/SalesApi.cs

@@ -0,0 +1,39 @@
+namespace IntegrationTest.Sales;
+
+using System.Net;
+using System.Threading.Tasks;
+using IntegrationTest.Shared;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.Functions.Worker.Http;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+[NServiceBusSendOnlyEndpoint]
+class SalesApi([FromKeyedServices("SalesApi")] IMessageSession session, ILogger<SalesApi> logger)
+{
+    [Function("SalesApi")]
+    public async Task<HttpResponseData> Api(
+        [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)]
+        HttpRequestData req,
+        CancellationToken cancellationToken)
+    {
+        logger.LogInformation("C# HTTP trigger function received a request.");
+
+        await session.Send(new SubmitOrder(), cancellationToken).ConfigureAwait(false);
+
+        var r = req.CreateResponse(HttpStatusCode.OK);
+        await r.WriteStringAsync($"{nameof(SubmitOrder)} sent.", cancellationToken).ConfigureAwait(false);
+        return r;
+    }
+
+    public static void ConfigureSalesApi(EndpointConfiguration configuration)
+    {
+        var transport = new AzureServiceBusServerlessTransport(TopicTopology.Default) { ConnectionName = "AzureWebJobsServiceBus" };
+
+        var routing = configuration.UseTransport(transport);
+
+        routing.RouteToEndpoint(typeof(SubmitOrder), "sales");
+        configuration.UseSerialization<SystemJsonSerializer>();
+    }
+}

src/IntegrationTest.Sales/SalesEndpoint.cs

@@ -0,0 +1,23 @@
+namespace IntegrationTest.Sales;
+
+using Azure.Messaging.ServiceBus;
+using IntegrationTest.Shared;
+using Microsoft.Azure.Functions.Worker;
+
+// Cleanest pattern for single-function endpoints
+[NServiceBusFunction]
+public partial class SalesEndpoint
+{
+    [Function("Sales")]
+    public partial Task Sales(
+        [ServiceBusTrigger("sales", Connection = "AzureWebJobsServiceBus", AutoCompleteMessages = true)]
+        ServiceBusReceivedMessage message,
+        FunctionContext functionContext,
+        CancellationToken cancellationToken = default);
+
+    public static void ConfigureSales(EndpointConfiguration configuration)
+    {
+        CommonEndpointConfig.Apply(configuration);
+        configuration.AddHandler<Handlers.AcceptOrderHandler>();
+    }
+}

src/IntegrationTest.Shared/CommonEndpointConfig.cs

@@ -0,0 +1,12 @@
+namespace IntegrationTest.Shared;
+
+public static class CommonEndpointConfig
+{
+    public static void Apply(EndpointConfiguration configuration)
+    {
+        configuration.UseTransport(new AzureServiceBusServerlessTransport(TopicTopology.Default));
+        configuration.EnableInstallers();
+        configuration.UsePersistence<LearningPersistence>();
+        configuration.UseSerialization<SystemJsonSerializer>();
+    }
+}

src/IntegrationTest.Shared/IntegrationTest.Shared.csproj

@@ -0,0 +1,11 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.AzureServiceBus\NServiceBus.AzureFunctions.AzureServiceBus.csproj" />
+  </ItemGroup>
+
+</Project>

src/IntegrationTest.Shared/OrderSubmitted.cs

@@ -0,0 +1,5 @@
+namespace IntegrationTest.Shared;
+
+using NServiceBus;
+
+public class OrderSubmitted : IEvent;

src/IntegrationTest.Shared/PaymentCleared.cs

@@ -0,0 +1,5 @@
+namespace IntegrationTest.Shared;
+
+using NServiceBus;
+
+public class PaymentCleared : IEvent;

src/IntegrationTest.Shared/SubmitOrder.cs

@@ -0,0 +1,5 @@
+namespace IntegrationTest.Shared;
+
+using NServiceBus;
+
+public class SubmitOrder : ICommand;

src/IntegrationTest.Shipping/Handlers/ShipOrderHandler.cs

@@ -0,0 +1,15 @@
+namespace IntegrationTest.Shipping.Handlers;
+
+using IntegrationTest.Shared;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+public class ShipOrderHandler(ILogger<ShipOrderHandler> logger) : IHandleMessages<PaymentCleared>
+{
+    public Task Handle(PaymentCleared message, IMessageHandlerContext context)
+    {
+        logger.LogWarning($"Handling {nameof(PaymentCleared)} in {nameof(ShipOrderHandler)}");
+
+        return Task.CompletedTask;
+    }
+}

src/IntegrationTest.Shipping/IntegrationTest.Shipping.csproj

@@ -0,0 +1,23 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <InterceptorsPreviewNamespaces>$(InterceptorsPreviewNamespaces);NServiceBus</InterceptorsPreviewNamespaces>
+    <EmitCompilerGeneratedFiles>true</EmitCompilerGeneratedFiles>
+    <CompilerGeneratedFilesOutputPath>$(BaseIntermediateOutputPath)\GeneratedFiles</CompilerGeneratedFilesOutputPath>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.AzureServiceBus\NServiceBus.AzureFunctions.AzureServiceBus.csproj" />
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.Analyzer\NServiceBus.AzureFunctions.Analyzer.csproj"
+                      OutputItemType="Analyzer"
+                      ReferenceOutputAssembly="false" />
+    <ProjectReference Include="..\IntegrationTest.Shared\IntegrationTest.Shared.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="2.51.0" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.ServiceBus" Version="5.24.0" />
+  </ItemGroup>
+
+</Project>

src/IntegrationTest.Shipping/ShippingEndpoint.cs

@@ -0,0 +1,22 @@
+namespace IntegrationTest.Shipping;
+
+using Azure.Messaging.ServiceBus;
+using IntegrationTest.Shared;
+using Microsoft.Azure.Functions.Worker;
+
+[NServiceBusFunction]
+public partial class ShippingEndpoint
+{
+    [Function(nameof(Shipping))]
+    public partial Task Shipping(
+        [ServiceBusTrigger("shipping", AutoCompleteMessages = true)]
+        ServiceBusReceivedMessage message,
+        FunctionContext functionContext,
+        CancellationToken cancellationToken = default);
+
+    public static void ConfigureShipping(EndpointConfiguration endpoint)
+    {
+        CommonEndpointConfig.Apply(endpoint);
+        endpoint.AddHandler<Handlers.ShipOrderHandler>();
+    }
+}

src/IntegrationTest/IntegrationTest.csproj

@@ -4,17 +4,24 @@
     <TargetFramework>net10.0</TargetFramework>
     <AzureFunctionsVersion>v4</AzureFunctionsVersion>
     <OutputType>Exe</OutputType>
+    <InterceptorsPreviewNamespaces>$(InterceptorsPreviewNamespaces);NServiceBus</InterceptorsPreviewNamespaces>
     <EmitCompilerGeneratedFiles>true</EmitCompilerGeneratedFiles>
     <CompilerGeneratedFilesOutputPath>$(BaseIntermediateOutputPath)\GeneratedFiles</CompilerGeneratedFilesOutputPath>
   </PropertyGroup>
 
   <ItemGroup>
     <ProjectReference Include="..\NServiceBus.AzureFunctions.AzureServiceBus\NServiceBus.AzureFunctions.AzureServiceBus.csproj" />
+    <ProjectReference Include="..\NServiceBus.AzureFunctions.Analyzer\NServiceBus.AzureFunctions.Analyzer.csproj"
+                      OutputItemType="Analyzer"
+                      ReferenceOutputAssembly="false" />
+    <ProjectReference Include="..\IntegrationTest.Shared\IntegrationTest.Shared.csproj" />
+    <ProjectReference Include="..\IntegrationTest.Sales\IntegrationTest.Sales.csproj" />
+    <ProjectReference Include="..\IntegrationTest.Billing\IntegrationTest.Billing.csproj" />
+    <ProjectReference Include="..\IntegrationTest.Shipping\IntegrationTest.Shipping.csproj" />
   </ItemGroup>
 
   <ItemGroup>
     <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="2.51.0" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http" Version="3.3.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Sdk" Version="2.0.7" />
   </ItemGroup>