NServiceBus: Wie Nachrichten aus der Fehlerwarteschlange verschoben werden

Question

Ich hatte einen Fehler in meiner Anwendung, die eine Anzahl von Nachrichten in die Fehlerwarteschlange verschoben werden. Nun, da ich den Fehler behoben habe, gibt es eine einfache Möglichkeit, sie zurück in die ursprüngliche Warteschlange zu verschieben, damit sie verarbeitet werden können.

Answer 1

Sie können das einfache Befehlszeilenprogramm ReturnToSourceQueue.exe verwenden, das in NServiceBus enthalten ist.

Es befindet sich in der tools Ordner IIRC.

Answer 2

private const string QUEUE_NAME = "private$\\localqueue"; 
    private const string ERROR_QUEUE_NAME = "private$\\localerrorqueue"; 

      if (!MessageQueue.Exists(".\\" + QUEUE_NAME)) 
       return; 

      if (!MessageQueue.Exists(".\\" + ERROR_QUEUE_NAME)) 
       return; 

      var messageQueues = MessageQueue.GetPrivateQueuesByMachine(Environment.MachineName); 

      var queue = messageQueues.Single(x => x.QueueName == QUEUE_NAME); 
      var errorQueue = messageQueues.Single(x => x.QueueName == ERROR_QUEUE_NAME); 

      var noOfErrorMessages = errorQueue.GetAllMessages().Count(); 

      if (noOfErrorMessages == 0) 
       return; 

      using (var transaction = new MessageQueueTransaction()) 
      { 
       transaction.Begin(); 

       for (var i = 0; i < noOfErrorMessages; i++) 
       { 
        var message = errorQueue.Receive(transaction); 
        queue.Send(message, transaction); 
       } 

       transaction.Commit(); 
      }