MassTransit3 с временной очередью

У меня есть веб-ферма с веб-садами, я хочу, чтобы каждый процесс получал уведомление, когда событие возникает из других процессов, это событие в основном используется для обновления внутренних кешей, например, если процесс обновляет `` клиента '', все другие процессы должны получать уведомления о что.

Каждый процесс создает шину с RabbitMQ, затем я настраиваю одну конечную точку с произвольным именем, где я регистрирую своих потребителей, это, кажется, работает, в любом случае в конце дня я нахожу множество мертвых очередей внутри RabbitMQ для переработанных процессов.

Я попытался использовать для этой цели временную очередь, но я не знаю, как опубликовать событие на шине и как мои потребители будут автоматически подключаться к нему, я попытался использовать методы ConnectXX, но они не устанавливают все необходимые привязки в RabbitMQ.

Любые идеи? Благодарность


person spartaco    schedule 28.06.2016    source источник


Ответы (1)


Этот код создает временную очередь:

cfg.ReceiveEndpoint(host, ec => { ... })
person spartaco    schedule 28.06.2016
comment
Простите меня за тупость, но это похоже на код, который я использовал для создания постоянной очереди. Что мне не хватает? - person Binary Worrier; 02.11.2016