Skip to content

Commit bbcfd10

Browse files
vladimir-pecanac-mainvladimir-pecanac-main
committed
MassTransitRabbitMQ: retarget net10.0, MassTransit 9.2.0, generic-host consumer
- All four projects net6.0 -> net10.0 - MassTransit and MassTransit.RabbitMQ 7.3.1 -> 9.2.0 - Drop MassTransit.AspNetCore reference and the obsolete AddMassTransitHostedService() call; the hosted service is registered automatically by AddMassTransit - Rewrite the consumer onto Host.CreateApplicationBuilder with AddConsumer<T>() and ConfigureEndpoints(), replacing the Bus.Factory.CreateUsingRabbitMq + manual StartAsync/StopAsync loop - Replace JsonConvert.SerializeObject with JsonSerializer.Serialize; MassTransit 9 no longer brings Newtonsoft.Json in transitively (CS0246) - OrderCreated message contract is get-only, per the immutable-message convention MassTransit materialises against
1 parent 7935946 commit bbcfd10

7 files changed

Lines changed: 29 additions & 38 deletions

File tree

‎aspnetcore-webapi/MassTransitRabbitMQ/Consumer/Consumer.csproj‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,15 @@
22

33
<PropertyGroup>
44
<OutputType>Exe</OutputType>
5-
<TargetFramework>net6.0</TargetFramework>
5+
<TargetFramework>net10.0</TargetFramework>
66
<ImplicitUsings>enable</ImplicitUsings>
77
<Nullable>enable</Nullable>
88
</PropertyGroup>
99

1010
<ItemGroup>
11-
<PackageReference Include="MassTransit" Version="7.3.1" />
12-
<PackageReference Include="MassTransit.RabbitMQ" Version="7.3.1" />
11+
<PackageReference Include="MassTransit" Version="9.2.0" />
12+
<PackageReference Include="Microsoft.Extensions.Hosting" Version="10.0.11" />
13+
<PackageReference Include="MassTransit.RabbitMQ" Version="9.2.0" />
1314
</ItemGroup>
1415

1516
<ItemGroup>

‎aspnetcore-webapi/MassTransitRabbitMQ/Consumer/Program.cs‎

Lines changed: 15 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -1,36 +1,29 @@
1-
using MassTransit;
2-
using Newtonsoft.Json;
1+
using MassTransit;
2+
using Microsoft.Extensions.Hosting;
33
using SharedModels;
4+
using System.Text.Json;
45

5-
var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
6+
var builder = Host.CreateApplicationBuilder(args);
7+
8+
builder.Services.AddMassTransit(x =>
69
{
7-
cfg.ReceiveEndpoint("order-created-event", e =>
10+
x.AddConsumer<OrderCreatedConsumer>();
11+
12+
x.UsingRabbitMq((context, cfg) =>
813
{
9-
e.Consumer<OrderCreatedConsumer>();
14+
cfg.ConfigureEndpoints(context);
1015
});
11-
1216
});
1317

14-
await busControl.StartAsync(new CancellationToken());
15-
16-
try
17-
{
18-
Console.WriteLine("Press enter to exit");
19-
20-
await Task.Run(() => Console.ReadLine());
21-
}
22-
finally
23-
{
24-
await busControl.StopAsync();
25-
}
18+
await builder.Build().RunAsync();
2619

2720
class OrderCreatedConsumer : IConsumer<OrderCreated>
2821
{
29-
public async Task Consume(ConsumeContext<OrderCreated> context)
22+
public Task Consume(ConsumeContext<OrderCreated> context)
3023
{
31-
var jsonMessage = JsonConvert.SerializeObject(context.Message);
24+
var jsonMessage = JsonSerializer.Serialize(context.Message);
3225
Console.WriteLine($"OrderCreated message: {jsonMessage}");
26+
27+
return Task.CompletedTask;
3328
}
3429
}
35-
36-

‎aspnetcore-webapi/MassTransitRabbitMQ/Producer/Producer.csproj‎

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,14 @@
11
<Project Sdk="Microsoft.NET.Sdk.Web">
22

33
<PropertyGroup>
4-
<TargetFramework>net6.0</TargetFramework>
4+
<TargetFramework>net10.0</TargetFramework>
55
<Nullable>enable</Nullable>
66
<ImplicitUsings>enable</ImplicitUsings>
77
</PropertyGroup>
88

99
<ItemGroup>
10-
<PackageReference Include="MassTransit" Version="7.3.1" />
11-
<PackageReference Include="MassTransit.AspNetCore" Version="7.3.1" />
12-
<PackageReference Include="MassTransit.RabbitMQ" Version="7.3.1" />
10+
<PackageReference Include="MassTransit" Version="9.2.0" />
11+
<PackageReference Include="MassTransit.RabbitMQ" Version="9.2.0" />
1312
</ItemGroup>
1413

1514
<ItemGroup>

‎aspnetcore-webapi/MassTransitRabbitMQ/Producer/Program.cs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,6 @@
88
x.UsingRabbitMq();
99
});
1010

11-
builder.Services.AddMassTransitHostedService();
12-
1311
builder.Services.AddControllers();
1412

1513
var app = builder.Build();

‎aspnetcore-webapi/MassTransitRabbitMQ/SharedModels/OrderCreated.cs‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
1-
namespace SharedModels
1+
namespace SharedModels
22
{
33
public interface OrderCreated
44
{
5-
int Id { get; set; }
5+
int Id { get; }
66

7-
string ProductName { get; set; }
7+
string ProductName { get; }
88

9-
decimal Price { get; set; }
9+
decimal Price { get; }
1010

11-
int Quantity { get; set; }
11+
int Quantity { get; }
1212
}
1313
}

‎aspnetcore-webapi/MassTransitRabbitMQ/SharedModels/SharedModels.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<Project Sdk="Microsoft.NET.Sdk">
22

33
<PropertyGroup>
4-
<TargetFramework>net6.0</TargetFramework>
4+
<TargetFramework>net10.0</TargetFramework>
55
<ImplicitUsings>enable</ImplicitUsings>
66
<Nullable>enable</Nullable>
77
</PropertyGroup>

‎aspnetcore-webapi/MassTransitRabbitMQ/Tests/Tests.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<Project Sdk="Microsoft.NET.Sdk">
22

33
<PropertyGroup>
4-
<TargetFramework>net6.0</TargetFramework>
4+
<TargetFramework>net10.0</TargetFramework>
55
<Nullable>enable</Nullable>
66

77
<IsPackable>false</IsPackable>

0 commit comments

Comments
 (0)