NServiceBus: how to move messages from the error queue

Question

I had an error in my application that caused several messages to be moved to the error queue. Now that I have fixed the error, is there an easy way to move them back to the original queue so that they can be processed?

Answer 1

You can use a simple command line tool, ReturnToSourceQueue.exe , which is included in NServiceBus.

It is located in the tools IIRC folder.

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(); }