Aspire with Rabbitmq integration sample

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.AppHost/AspireWithRabbitMQ.AppHost.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <IsAspireHost>true</IsAspireHost>
+    <UserSecretsId>fcac3554-ac4d-4ee1-88a6-f808f54a59d8</UserSecretsId>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Aspire.Hosting.AppHost" Version="8.2.0" />
+    <PackageReference Include="Aspire.Hosting.RabbitMQ" Version="8.2.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\AspireWithRabbitMQ.Sender\AspireWithRabbitMQ.Sender.csproj" />
+    <ProjectReference Include="..\AspireWithRabbitMQ.Receiver\AspireWithRabbitMQ.Receiver.csproj" />
+  </ItemGroup>
+
+</Project>

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.AppHost/Program.cs

@@ -0,0 +1,11 @@
+var builder = DistributedApplication.CreateBuilder(args);
+
+var rabbitMQ = builder.AddRabbitMQ("messaging").WithManagementPlugin();
+
+builder.AddProject<Projects.AspireWithRabbitMQ_Sender>("sender")
+.WithReference(rabbitMQ);
+
+builder.AddProject<Projects.AspireWithRabbitMQ_Receiver>("receiver")
+.WithReference(rabbitMQ);
+
+builder.Build().Run();

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.AppHost/Properties/launchSettings.json

@@ -0,0 +1,29 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:17004;http://localhost:15150",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "DOTNET_ENVIRONMENT": "Development",
+        "DOTNET_DASHBOARD_OTLP_ENDPOINT_URL": "https://localhost:21011",
+        "DOTNET_RESOURCE_SERVICE_ENDPOINT_URL": "https://localhost:22000"
+      }
+    },
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:15150",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "DOTNET_ENVIRONMENT": "Development",
+        "DOTNET_DASHBOARD_OTLP_ENDPOINT_URL": "http://localhost:19039",
+        "DOTNET_RESOURCE_SERVICE_ENDPOINT_URL": "http://localhost:20187"
+      }
+    }
+  }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.AppHost/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.AppHost/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning",
+      "Aspire.Hosting.Dcp": "Warning"
+    }
+  }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Receiver/AspireWithRabbitMQ.Receiver.csproj

@@ -0,0 +1,17 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Aspire.RabbitMQ.Client" Version="8.2.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\AspireWithRabbitMQ.ServiceDefaults\AspireWithRabbitMQ.ServiceDefaults.csproj" />
+  </ItemGroup>
+
+</Project>

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Receiver/ProcessRabbitMQMessage.cs

@@ -0,0 +1,53 @@
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+using RabbitMQ.Client.Events;
+using RabbitMQ.Client;
+using System.Text;
+
+public class ProcessRabbitMQMessage : BackgroundService{
+    private readonly ILogger<ProcessRabbitMQMessage> _logger;
+    private readonly IServiceProvider _serviceProvider;
+    private IConnection? _messageConnection;
+    private IModel? _messageChannel;
+    private EventingBasicConsumer consumer;
+
+    public ProcessRabbitMQMessage(ILogger<ProcessRabbitMQMessage> logger, IServiceProvider serviceProvider, IConnection? messageConnection)
+    {
+        _logger = logger;
+        _serviceProvider = serviceProvider;
+    }
+
+    protected override Task ExecuteAsync(CancellationToken stoppingToken)
+    {
+        string queueName = "testMessage";
+        _messageConnection = _serviceProvider.GetRequiredService<IConnection>();
+
+        _messageChannel = _messageConnection.CreateModel();
+        _messageChannel.QueueDeclare(queue: queueName,
+            durable: false,
+            exclusive: false,
+            autoDelete: false,
+            arguments: null);
+
+        consumer = new EventingBasicConsumer(_messageChannel);
+        consumer.Received += ProcessMessageAsync;
+
+        _messageChannel.BasicConsume(queue: queueName,
+            autoAck: true,
+            consumer: consumer);
+        return Task.CompletedTask;
+    }
+    public override async Task StopAsync(CancellationToken cancellationToken)
+    {
+        await base.StopAsync(cancellationToken);
+        consumer.Received -= ProcessMessageAsync;
+        _messageChannel?.Dispose();
+    }
+    private void ProcessMessageAsync(object? sender, BasicDeliverEventArgs args)
+    {
+        string message = Encoding.UTF8.GetString(args.Body.ToArray());
+        _logger.LogInformation("Message retrieved from queue at {now}. Message Text: {text}", DateTime.Now, message);
+       // var message = args.Body;
+    }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Receiver/Program.cs

@@ -0,0 +1,12 @@
+using RabbitMQ.Client;
+using System.Text;
+
+var builder = WebApplication.CreateBuilder(args);
+builder.AddServiceDefaults();
+builder.AddRabbitMQClient("messaging");
+
+builder.Services.AddHostedService<ProcessRabbitMQMessage>();
+
+var app = builder.Build();
+app.Run();
+

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Receiver/Properties/launchSettings.json

@@ -0,0 +1,41 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:4257",
+      "sslPort": 44326
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "weatherforecast",
+      "applicationUrl": "http://localhost:5102",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "weatherforecast",
+      "applicationUrl": "https://localhost:7217;http://localhost:5102",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "weatherforecast",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Receiver/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Receiver/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Sender/AspireWithRabbitMQ.Sender.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Aspire.RabbitMQ.Client" Version="8.2.0" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.7.3" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\AspireWithRabbitMQ.ServiceDefaults\AspireWithRabbitMQ.ServiceDefaults.csproj" />
+  </ItemGroup>
+
+</Project>

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Sender/Program.cs

@@ -0,0 +1,41 @@
+using RabbitMQ.Client;
+using System.Text;
+
+var builder = WebApplication.CreateBuilder(args);
+builder.AddServiceDefaults();
+builder.AddRabbitMQClient("messaging");
+
+builder.Services.AddProblemDetails();
+builder.Services.AddEndpointsApiExplorer();
+builder.Services.AddSwaggerGen();
+
+var app = builder.Build();
+app.UseSwagger();
+app.UseSwaggerUI();
+app.UseHttpsRedirection();
+
+app.MapPost("sendmessage",async Task<IResult>(IConnection connection, string messageToSend)=>{
+
+    var channel = connection.CreateModel();
+    channel.QueueDeclare(
+        queue:"testMessage",
+        durable:false,
+        exclusive:false,
+        autoDelete:false,
+        arguments:null
+    );
+    var body = Encoding.UTF8.GetBytes(messageToSend);
+
+    channel.BasicPublish(
+        exchange:string.Empty,
+        routingKey:"testMessage",
+        mandatory:false,
+        basicProperties:null,
+        body:body
+    );
+    return Results.Ok(new {});
+
+});
+app.Run();
+
+

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Sender/Properties/launchSettings.json

@@ -0,0 +1,41 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:45524",
+      "sslPort": 44320
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "applicationUrl": "http://localhost:5095",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "applicationUrl": "https://localhost:7138;http://localhost:5095",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Sender/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.Sender/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

samples/AspireWithRabbitMQ/AspireWithRabbitMQ.ServiceDefaults/AspireWithRabbitMQ.ServiceDefaults.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <IsAspireSharedProject>true</IsAspireSharedProject>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <FrameworkReference Include="Microsoft.AspNetCore.App" />
+
+    <PackageReference Include="Microsoft.Extensions.Http.Resilience" Version="8.8.0" />
+    <PackageReference Include="Microsoft.Extensions.ServiceDiscovery" Version="8.2.0" />
+    <PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Runtime" Version="1.9.0" />
+  </ItemGroup>
+
+</Project>