Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

MassTransit with RabbitMQ: recovering the error queue

This is probably a very simple answer, but I'm not seeing an obvious solution in the MassTransit docs or forums.

When you have some messages that have been moved over to the error queue in RabbitMQ, what's the best mechanism for getting them back into the processing queue? Also, is there any built-in logging of why they got moved over there in the first place?

like image 915
JoshRivers Avatar asked May 08 '12 16:05

JoshRivers


People also ask

What does MassTransit add to RabbitMQ?

MassTransit provides a heavily production tested convention for using RabbitMQ exchanges to route published messages to the subscribed consumers. The structure is CPU and memory friendly, which keeps RabbitMQ happy.

What is MassTransit in RabbitMQ?

What is MassTransit? MassTransit is a free, open-source, distributed application framework for . NET applications. It abstracts away the underlying logic required to work with message brokers, such as RabbitMQ, making it easier to create message-based, loosely coupled applications.

What is MassTransit saga?

A saga is a long-lived transaction managed by a coordinator. Sagas are initiated by an event, sagas orchestrate events, and sagas maintain the state of the overall transaction. Sagas are designed to manage the complexity of a distributed transaction without locking and immediate consistency.


1 Answers

Enable logging with the right plugin (NLog, log4net, etc) and failures should be in the log, assuming the right log level is enabled.

There is no great way to move messages back. Dru has worked on a busdriver tool https://github.com/MassTransit/MassTransit/tree/master/src/Tools/BusDriver. This, I believe, will allow you move items from one queue to another - but it's not a tool I've used. I have historically written tools that are related to business processes to move items back to the proper queue for processing that ops will manage.

like image 188
Travis Avatar answered Oct 07 '22 02:10

Travis