2016-06-28 3 views
0

У меня есть webfarm с webgardens, я хочу, чтобы каждый процесс получал уведомление, когда событие возникает из других процессов, это событие в основном используется для обновления внутренних кешей, например, если процесс обновляет «клиент», все другие процессы должны получить уведомление об этом.MassTransit3 с временной очередью

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

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

Любые идеи? благодаря

ответ

0

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

cfg.ReceiveEndpoint(host, ec => { ... }) 
+0

Прости меня за то, что тупые, но выглядит идентично код, который я бы использовать, чтобы создать постоянную очередь. Что мне не хватает? –

Смежные вопросы