Updated SampleApi and README

Author: Anders Tøgersen (Delegate)

Atc.Azure.Messaging.sln

@@ -7,11 +7,6 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Atc.Azure.Messaging", "src\
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Atc.Azure.Messaging.Tests", "test\Atc.Azure.Messaging.Tests\Atc.Azure.Messaging.Tests.csproj", "{0C49EE44-DAE3-4A7C-9D2D-D1190CAC85F0}"
 EndProject
-Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{5F9CEB97-F31C-493F-9FF4-EF94F8169B80}"
-	ProjectSection(SolutionItems) = preProject
-		version.json = version.json
-	EndProjectSection
-EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU

README.md

@@ -37,6 +37,46 @@ builder.Services.AddSwaggerGen();
 builder.Services.ConfigureMessagingServices(builder.Configuration);
 ```
 
+## Connecting with Managed Identity
+
+When connecting with Managed Identity you need to setup your configuration accordingly.
+
+The following is an example of how you would configure your EventHub or ServiceBus with Managed Identity for [ATC Azure Options](https://github.com/atc-net/atc-azure-options)
+
+```json
+{  
+  "EventHubOptions": {
+    "FullyQualifiedNamespace": "[your eventhub namespace].servicebus.windows.net"
+  },
+  "ServiceBusOptions": {
+    "FullyQualifiedNamespace": "[your servicebus namespace].servicebus.windows.net"
+  },
+  "ClientAuthorizationOptions": {
+    "TenantId": "[your tenant id]"
+  },
+  "EnvironmentOptions": {
+    "EnvironmentType": "[Local/DevTest/Production]"
+  }
+}
+```
+
+It is important that the logged-in user/application has the `Azure Service Bus Data Sender` or `Azure Service Bus Data Owner` build-in role for [ServiceBus](https://learn.microsoft.com/en-us/azure/service-bus-messaging/service-bus-managed-service-identity#azure-built-in-roles-for-azure-service-bus).
+
+And the corresponding `Azure Event Hubs Data Sender` or `Azure Event Hubs Data Owner` build-in roles for [Eventhubs](https://learn.microsoft.com/en-us/azure/event-hubs/authenticate-application#built-in-roles-for-azure-event-hubs)
+
+The dependencies are registered using `ConfigureMessagingServices(IConfiguration, bool)` for the default implementation of [IAzureCredentialOptionsProvider](https://github.com/atc-net/atc-azure-options/blob/main/src/Atc.Azure.Options/Providers/AzureCredentialOptionsProvider.cs) and `ConfigureMessagingServices(IConfiguration, bool, IAzureCredentialOptionsProvider)` if you wish to use your own implementation of `IAzureCredentialOptionsProvider`.
+
+Here's an example of the default implementation using a Minimal API setup
+
+```csharp
+var builder = WebApplication.CreateBuilder(args);
+builder.Services.AddEndpointsApiExplorer();
+builder.Services.AddSwaggerGen();
+
+// Register Atc.Azure.Messaging dependencies
+builder.Services.ConfigureMessagingServices(builder.Configuration, true);
+```
+
 ## Publishing to EventHub
 
 To publish events to an EventHub you need an instance of `IEventHubPublisher`, this can be constructed via the `IEventHubPublisherFactory` which exposes the `Create(string eventHubName)` method

sample/SampleApi/Program.cs

@@ -12,7 +12,7 @@
 builder.Services.AddSingleton<SendDataHandler>();
 
 // Register Atc.Azure.Messaging dependencies
-builder.Services.ConfigureMessagingServices(builder.Configuration);
+builder.Services.ConfigureMessagingServices(builder.Configuration); // ConfigureMessagingServices(builder.Configuration, true)
 
 var app = builder.Build();
 app.UseHttpsRedirection();
@@ -38,15 +38,14 @@ public SendDataHandler(
         IEventHubPublisherFactory eventHubFactory,
         IServiceBusPublisher serviceBusPublisher)
     {
-        eventHubPublisher = eventHubFactory.Create("[existing eventhub");
+        eventHubPublisher = eventHubFactory.Create("[existing eventhub]");
         this.serviceBusPublisher = serviceBusPublisher;
     }
 
     public async Task<Response> Post(Request request)
     {
         await eventHubPublisher.PublishAsync(request);
-
-        await serviceBusPublisher.PublishAsync("existing topic|queue", request);
+        await serviceBusPublisher.PublishAsync("[existing topic|queue]", request);
 
         return new Response(
             Guid.NewGuid().ToString("N"),

sample/SampleApi/appsettings.json

@@ -8,5 +8,14 @@
   "AllowedHosts": "*",
   "EventHubOptions": {
     "ConnectionString": "Endpoint=sb://[your eventhub namespace].servicebus.windows.net/;SharedAccessKeyName=[eventhub name];SharedAccessKey=[sas key]"
+  },
+  "ServiceBusOptions": {
+    "FullyQualifiedNamespace": "[your servicebus namespace].servicebus.windows.net"
+  },
+  "ClientAuthorizationOptions": {
+    "TenantId": "[your tenant id]"
+  },
+  "EnvironmentOptions": {
+    "EnvironmentType": "Local"
   }
 }