how to consumer client with specific user and vhost

[maxime-aubry]

Hello,

I try to consume RabbitMQ client with specific user and vhost.

Here is a part of my AppHost :

IResourceBuilder<RabbitMQServerResource> rabbitmq = builder.AddRabbitMQ("custom-host", "admin", "admin")
    .WithDataVolume("rabbitmq_data")
    .WithManagementPlugin();

IResourceBuilder<ProjectResource> usersService = builder.AddProject<Projects.Users_API>("users-api")
    .WithReference(rabbitmq)
    .WaitFor(rabbitmq);

here is a part of program.cs of users-api

public static TBuilder AddApiLayerServices<TBuilder>(this TBuilder builder) where TBuilder : IHostApplicationBuilder
{
    builder.AddServiceDefaults();
    builder.AddFastEndpointsService();
    builder.AddKeycloakService();
    builder.AddMassTransitService((IBusRegistrationConfigurator config) =>
    {
        config.AddConsumer<UserUpdateEmailEventConsumer, UserUpdateEmailEventConsumerDefinition>();
    });

    return builder;
}

public static TBuilder AddMassTransitService<TBuilder>(
    this TBuilder builder,
    Action<IBusRegistrationConfigurator>? addConsumers = null
)
    where TBuilder: IHostApplicationBuilder
{
   builder.AddMassTransitRabbitMq<ISecondBus>(
        "custom-host",
        configureOptions: (MassTransitRabbitMqSettings config) =>
        {

        },
        massTransitConfiguration: (IBusRegistrationConfigurator config) =>
        {
            config.AddConfigureEndpointsCallback((IRegistrationContext context, string endpointName, IReceiveEndpointConfigurator endpointConfigurator) =>
            {
                endpointConfigurator.UseMessageRetry((IRetryConfigurator retry) => retry.Interval(10, TimeSpan.FromSeconds(10)));
            });
            addConsumers?.Invoke(config);
        }
    );

    return builder;
}

I want to use admin account for user interface of rabbitmq. But i want to use users-api-consumer account in users-api project.
Unfortunately, i get a connection string with admin account + password, and no specific vhost.

ConnectionString:custom-host = amqp://admin:admin@localhost:51041

what can i do ?

Thanks :)