services.AddMassTransit(opt =>
{
opt.SetKebabCaseEndpointNameFormatter();
opt.AddConsumer<UserRegisteredEventHandler>();
opt.AddEntityFrameworkOutbox<TContext>(o =>
{
o.QueryDelay = TimeSpan.FromSeconds(1);
o.UsePostgres();
o.UseBusOutbox();
});
opt.UsingRabbitMq((context, o) =>
{
o.Host("localhost", "/", h =>
{
h.Username("user123");
h.Password("pass123");
});
o.ConfigureEndpoints(context);
});
});
services.AddMassTransit(opt =>
{
opt.SetKebabCaseEndpointNameFormatter();
opt.AddConsumer<UserRegisteredEventHandler>();
opt.AddEntityFrameworkOutbox<TContext>(o =>
{
o.QueryDelay = TimeSpan.FromSeconds(1);
o.UsePostgres();
o.UseBusOutbox();
});
opt.UsingRabbitMq((context, o) =>
{
o.Host("localhost", "/", h =>
{
h.Username("user123");
h.Password("pass123");
});
o.ConfigureEndpoints(context);
});
});