MassTransit und RabbitMQ, make Warteschlange überleben Neustart bei Verwendung von DI

Question

Ich versuche zu zwingen, die RabbitMQ-Warteschlangen den Rabbit-Dienst-Neustart zu überleben, während sie den gleichen Namen nach dem Neustart des Dienstes erneut verwenden erforderlich ist.

Wir verwenden unsere DI-Container die Nachricht Verbraucher

return new List<Type> 
{ 
    typeof(Consumer1), typeof(Consumer2), typeof(Consumer3), typeof(Consumer4) 
}; 

Diese Sammlung dann in die Konfigurations über

t => _kernel.Get(t)); 

Und dann sie übergeben wird passieren auf diese Weise Registrierung

cfg.ReceiveEndpoint(host, e => 
{ 
    foreach (var type in consumerTypes) 
    { 
     e.Consumer(type, getConsumer); 
    } 
}); 

Dadurch wird die Warteschlange bei jedem Neustart mit einer GUID im Namen neu erstellt.

Wenn wir versuchen, dies zu tun:

cfg.ReceiveEndpoint(host, e => 
{ 
    foreach (var type in consumerTypes) 
    { 
     e.Consumer(type, getConsumer); 
     e.Durable = true; 
     e.AutoDelete = false; 
    } 
}); 

Dann ist die Warteschlange dauerhaft, ist aber nicht auf Service Neustart erstellt.

Wie können wir einen Warteschlangennamen für jeden Verbraucher angeben?

Answer 1

Gelöst dies zu tun:

foreach (var type in consumerTypes) 
{ 
    var consumerType = type; 
    var queueName = string.Format("{0}_{1}", 
     Environment.MachineName, consumerType.ToString()); 
    cfg.ReceiveEndpoint(host, queueName, 
     e => 
     { 
      e.Consumer(consumerType, getConsumer); 
     }); 
}