Aplicação distribuída usando RabbitMQ

Estou a caminho de criar um aplicativo com 4 contextos delimitados usando CQRS & fornecimento de eventos.

Para fazer com que esses contextos limitados se comuniquem, eu planejava usar o Rabbit MQ.

Meus requisitos são os seguintes:

• O contexto limitado não deve conhecer um ao outro
• O contexto limitado não deve ser impedido se o outro contexto limitado estiver inativo ou se rabbitMQ estiver inativo
• Se um contexto limitado não estiver disponível, as mensagens, que ele deve receber, devem esperar pacientemente pelo seu retorno, ou seja: todo evento publicado deve ser encaminhado pelo menos uma vez para todos os bc interessados.

Portanto, eu estava pensando em fazer com que cada um deles fizesse referência a uma fila: BandMasterQueue e cria se não for.

Ao produzir um evento, a loja de eventos o armazena e seu envio consiste em duas etapas:

1. projete em si este evento para cada pequena projeção. Cada projeção tem um pequeno estoque de eventos já projetados para garantir a idempotência ao longo de algum período de tempo.
2. publique este evento na fila BandMasterQueue

se ele falhar na etapa 2 devido a nenhum rabbitmq disponível, então espero que minha loja de eventos tente enviar novamente a mensagem para o RabbitMQ depois de algum tempo (não exatamente com precisão sobre essa parte, devo dizer ...)

O "contexto limitado" do bandMaster conhece cada BC diferente que ele cuida. Ele é quem está lendo o bandMasterQueue e decide quais eventos são públicos e quais não são. Ele também é responsável por lidar com as "sagas" e pode enviar ações corretivas para cada bc.

Para fazer isso, ele se comunicará com cada contexto limitado usando a fila dedicada do contexto limitado e o criará se não sair.

Cada BC é vinculado a essa fila específica e adiciona o evento proveniente de fora em seu próprio armazenamento de eventos e depois projeta-o para sua própria projeção.

Esta "arquitetura" deve funcionar ou você vê alguma falha importante nela?