Как сделать так, чтобы Ребус хорошо играл с настраиваемым обменом темами в RabbitMQ?

Мне кажется, вы хотите сделать что-то вроде этого:

Configure.With(yourFavoriteContainer)
         .Transport(t => t.UseRabbitMq(...)
                          .ManageSubscriptions()) //< BAM!!1
         .(...)

что позволяет Ребусу воспользоваться тем фактом, что RabbitMqMessageQueue Ребуса реализует IMulticastTransport, что, в свою очередь, переключает обработку всей многоадресной рассылки на Rabbit.

Просто важно, чтобы все ваши конечные точки Rebus с поддержкой Rabbit согласились разрешить Rabbit ManageSubscriptions - иначе могут произойти странные вещи;)

Это означает, что

• когда вы bus.Subscribe<SomeEvent>, вы привязываете тему с именем типа к входной очереди подписчика - например, "SomeEvent.SomeNamespace" -> myInputQueue
• издатели публикуют события по теме, которая является названием типа - например, "SomeEvent.SomeNamespace"
• право собственности на сообщение не принимается во внимание при подписке
• Rabbit сделает тяжелую работу при многоадресной рассылке (что в основном и делают пользователи Rabbit).

Если вам требуется еще большая гибкость, вы даже можете взять на себя ответственность за выбор темы для публикации для каждого типа .NET, например:

Configure.With(yourFavoriteContainer)
         .Transport(t => t.UseRabbitMq(...)
                          .ManageSubscriptions()
                          .AddEventNameResolver(type => DecideTopic(type))
         .(...)

Вы можете добавить несколько преобразователей имен событий, если хотите - они будут запускаться последовательно, пока один из них не вернет что-то, отличное от null.

Имеет ли это смысл?