Miałem błąd w mojej aplikacji, który spowodował przeniesienie pewnej liczby wiadomości do kolejki błędów. Teraz, gdy naprawiłem błąd, czy istnieje prosty sposób przeniesienia ich z powrotem do pierwotnej kolejki, aby można je było przetworzyć?NServiceBus: Jak przenosić wiadomości z kolejki błędów
7
A
Odpowiedz
11
Możesz użyć prostego narzędzia wiersza poleceń, ReturnToSourceQueue.exe
, które jest dołączone do NServiceBus.
Znajduje się w folderze IIRC katalogu tools
.
4
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();
}
Powiązane problemy
- 1. Kolejki komunikatów NServiceBus buduje się
- 2. Nie automatycznego tworzenia kolejki NServiceBus
- 3. MassTransit z RabbitMQ: odzyskiwanie kolejki błędów
- 4. NServiceBus i NHibernate - Obsługa wiadomości i transakcje
- 5. Jak przenosić wiele wiadomości w mutt
- 6. Jak mogę usunąć wiadomości z kolejki?
- 7. Przeniesienie wiadomości z kolejki martwej litery do kolejki wychodzącej MSMQ
- 8. RabbitMQ - wybiórcze pobieranie wiadomości z kolejki
- 9. ActiveMQ nie odbiera wiadomości z kolejki
- 10. MassTransit z RabbitMQ: Kiedy wiadomość została przeniesiona do kolejki błędów
- 11. Jak mogę wstrzyknąć wiele repozytoriów w obsługę wiadomości NServicebus?
- 12. SendOnly w NServiceBus
- 13. Jak zrobić start_url w scrapy do pobrania z kolejki wiadomości?
- 14. Jak poprawnie uzyskać wszystkie wiadomości kolejki z RabbitMQ na wiosnę?
- 15. Używanie RabbitMQ z nServiceBus (dla C#) vs używanie Amazon SQS
- 16. Połączenia z Microservice do Microservice, autoryzacja z wiadomości kolejki
- 17. Czy kolejki wiadomości są przestarzałe w Linuksie?
- 18. Używanie MongoDB jako kolejki wiadomości dla Celery
- 19. Gdzie jest przechowywana zawartość kolejki wiadomości?
- 20. Jak przenosić elementy listy?
- 21. Jak usunąć komunikat z kolejki JMS
- 22. Czy można przenosić z char?
- 23. Różnica między Bus.Publish i Bus.Send w NServiceBus?
- 24. Konserwacja kolejki MassTransit
- 25. Kod błędu Obsługa błędów wiadomości e-mail
- 26. Czy mogę wysyłać wiadomości do kolejki JMS spoza serwera aplikacji?
- 27. pika.exceptions.ProbableAuthenticationError podczas próby wysłania wiadomości do kolejki zdalnej
- 28. Zarządzanie sesją RavenDb w Windsor pod NServiceBus
- 29. NServiceBus: Co stanie się z opublikowaną wiadomością, jeśli mój komputer abonencki jest wyłączony?
- 30. android - co jest ankietą macierzystą kolejki wiadomości raz na Androida?
A jeśli odzwierciedlasz te złożenia, bardzo łatwo jest dowiedzieć się, jak wykonać dodatkowe oprzyrządowanie otaczające ten proces, aby nie trzeba było logować się na serwerze i uruchamiać narzędzia wiersza poleceń. –