Comments…

dannythunder · Apr 27, 2023 · ee8bb47 · ee8bb47
1 parent 8c4bf16
commit ee8bb47
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/Wolverine.Mediator.RabbitMq.ReceiverDual/Helpers/MessagebrokerMessagesHelper.cs b/Wolverine.Mediator.RabbitMq.ReceiverDual/Helpers/MessagebrokerMessagesHelper.cs
@@ -5,7 +5,7 @@ namespace Wolverine.Mediator.RabbitMq.ReceiverDual.Helpers;
 
 public class MessagebrokerMessagesHelper
 {
-    public static Type[] EXTERNAL_EVENTS => new[]
+    public static Type[] EXTERNAL_EVENTS_TYPES => new[]
     {
         // From service Wolverine.Mediator.RabbitMq.Sender
         typeof(RemoteEvent),
@@ -15,7 +15,7 @@ public class MessagebrokerMessagesHelper
         // From a third service
     };
 
-    public static Type[] SERVICE_COMMANDS => new[]
+    public static Type[] SERVICE_COMMANDS_TYPES => new[]
     {
         // From service Wolverine.Mediator.RabbitMq.Sender
         typeof(RemoteCommand)

diff --git a/Wolverine.Mediator.RabbitMq.ReceiverDual/Program.cs b/Wolverine.Mediator.RabbitMq.ReceiverDual/Program.cs
@@ -18,8 +18,12 @@
     var connectionString = builder.Configuration.GetConnectionString("MessageBroker");
 
     opts.UseRabbitMq(new Uri(connectionString))
-        .AddQueueBindingsForMessages(queueName, MessagebrokerMessagesHelper.SERVICE_COMMANDS)  // Messages for this service
-        .AddQueueBindingsForMessages(queueName, MessagebrokerMessagesHelper.EXTERNAL_EVENTS)   // Events from other services
+
+        // These are essentially
+        //opts.DeclareExchange(exchangeName: type.Name).BindExchange(exchangeName: type.Name).ToQueue(queueName: queueName, bindingKey: type.Name);
+        .AddQueueBindingsForMessages(queueName, MessagebrokerMessagesHelper.SERVICE_COMMANDS_TYPES)  // Messages for this service
+        .AddQueueBindingsForMessages(queueName, MessagebrokerMessagesHelper.EXTERNAL_EVENTS_TYPES)   // Events from other services
+
         .AutoProvision();
 
     opts.ListenToRabbitQueue(queueName, q =>