NServiceBus: Cómo mover mensajes de la cola de errores

Question

Tuve un error en mi aplicación que causaba que varios mensajes se movieran a la cola de errores. Ahora que arreglé el error, ¿hay alguna manera simple de moverlos a la cola original para que puedan procesarse?

Answer 1

Puede utilizar una herramienta de línea de comandos simple, ReturnToSourceQueue.exe, que se incluye con NServiceBus.

Se encuentra en la carpeta tools 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(); 
      }