No working way for UseCase Aspire+MassTransit+RabbitMq+MessagePackSerializer #663

Activity

1. migoldfinger commented on Apr 30, 2025

   

   migoldfinger

   on Apr 30, 2025

   Author

   More actions

   Partial success I was able to register MassTransitSerializer, I just had to write an own custom extension

   public static class CustomExtensions
   {
   	public static void AddMassTransitRabbitMq(this IHostApplicationBuilder builder,
   		string name,
   		Action<MassTransitRabbitMqSettings>? configureOptions = null,
   		Action<IBusRegistrationConfigurator>? massTransitConfiguration = null,
   		Action<IRabbitMqBusFactoryConfigurator>? rabbitMqConfiguration = null
   	)
   	{
   		AddMassTransitRabbitMq<IBus>(builder, name, configureOptions, massTransitConfiguration, rabbitMqConfiguration);
   	}
   
   	public static void AddMassTransitRabbitMq<TBus>(this IHostApplicationBuilder builder,
   		string name,
   		Action<MassTransitRabbitMqSettings>? configureOptions = null,
   		Action<IBusRegistrationConfigurator>? massTransitConfiguration = null,
   		Action<IRabbitMqBusFactoryConfigurator>? rabbitMqConfiguration = null
   	)
   		where TBus : class, IBus
   	{
   		ArgumentNullException.ThrowIfNull(builder);
   		ArgumentNullException.ThrowIfNull(name);
   		ArgumentException.ThrowIfNullOrWhiteSpace(name);
   
   		var options = new MassTransitRabbitMqSettings();
   		configureOptions?.Invoke(options);
   		string? rabbitMqConnectionString = builder.Configuration["ConnectionStrings:" + name];
   
   		if (string.IsNullOrWhiteSpace(rabbitMqConnectionString))
   		{
   			throw new InvalidOperationException("RabbitMQ connection string is missing or empty in configuration.");
   		}
   
   		GlobalTopology.Send.UseRoutingKeyFormatter<WeatherRequestMessage>(static x => string.Empty);
   		GlobalTopology.Send.TryAddConvention(new RoutingKeySendTopologyConvention());
   
   		builder.Services.AddMassTransit<TBus>(x =>
   		                                      {
   			                                      x.SetKebabCaseEndpointNameFormatter();
   			                                      x.SetInMemorySagaRepositoryProvider();
   			                                      var entryAssembly = Assembly.GetEntryAssembly();
   			                                      x.AddSagaStateMachines(entryAssembly);
   			                                      x.AddSagas(entryAssembly);
   			                                      x.AddActivities(entryAssembly);
   
   			                                      massTransitConfiguration?.Invoke(x);
   
   			                                      x.UsingRabbitMq((context, cfg) =>
   			                                                      {
   				                                                      cfg.Host(new Uri(rabbitMqConnectionString));
   				                                                      cfg.ConfigureEndpoints(context);
   				                                                      rabbitMqConfiguration?.Invoke(cfg);
   			                                                      });
   		                                      });
   
   		if (!options.DisableTelemetry)
   		{
   			builder.Services
   			       .AddOpenTelemetry()
   			       .WithMetrics(static b => b.AddMeter(DiagnosticHeaders.DefaultListenerName))
   			       .WithTracing(static providerBuilder => { providerBuilder.AddSource(DiagnosticHeaders.DefaultListenerName); });
   		}
   	}
   }
   

   I then could call in Program.cs

   builder.AddMassTransitRabbitMq("MessageBus",
                                   massTransitConfiguration: static configurator =>
                                                             {
   configurator.AddRequestClient<WeatherRequestMessage>();
                                                             },
                                   rabbitMqConfiguration: static configurator =>
                                                          {
   	                                                       configurator.UseMessagePackSerializer();
                                                          });
   

   After that, MessagePack was used. I still struggle to find a way to use existing Exchanges and Queues.
2. CommunityToolkit

   locked and limited conversation to collaborators on May 2, 2025
3. aaronpowell

   converted this issue into a discussion #668 on May 2, 2025