Programmiererforum

   services.AddMassTransit(x =>
{
x.AddConsumer();

x.UsingAzureServiceBus((context, cfg) =>
{
cfg.UseMessageRetry(f =>
{
f.Interval(3, TimeSpan.FromSeconds(1));
});

cfg.Host($"sb://{options.Url}", x =>
{
x.TokenCredential = AzureCredentials.GetCredentials();
});

cfg.ReceiveEndpoint("dedupe-queue", e =>
{
e.AutoStart = true;
e.ConfigureConsumer(context);
});

cfg.ConfigureEndpoints(context);
});
});

Ich versuche herauszufinden, warum der Massentransit die gleiche Warteschlangennachricht aus dem Azure Service Bus zu konsumieren scheint. Es tut dies einmal für jede Instanz meiner Bewerbung. Hier ist meine Konfiguration. Ich war nicht auf Probleme gestoßen, bis ich den Dienst bis zu 3 Instanzen von 1 skalierte - und jetzt scheint es, dass jede Instanz den Artikel aus der Warteschlange greifen kann. < /P>
[code] services.AddMassTransit(x =>
{
x.AddConsumer();

x.UsingAzureServiceBus((context, cfg) =>
{
cfg.UseMessageRetry(f =>
{
f.Interval(3, TimeSpan.FromSeconds(1));
});

cfg.Host($"sb://{options.Url}", x =>
{
x.TokenCredential = AzureCredentials.GetCredentials();
});

cfg.ReceiveEndpoint("dedupe-queue", e =>
{
e.AutoStart = true;
e.ConfigureConsumer(context);
});

cfg.ConfigureEndpoints(context);
});
});
[/code]
Danke.