00

DDO_Application/Model/MessageProducer.cs

@@ -17,6 +17,8 @@ namespace DDO_Application.Model {
             msg.MessageId = "e6c77d95-54a7-4645-818b-16fd71322b6e";
             msg.MessageId = "e6c77d95-54a7-4645-818b-16fd71322b6e";
             
             
             await _producer.SendAsync(msg);
             await _producer.SendAsync(msg);
+
+       
         }
         }
     }
     }
 }
 }
\ No newline at end of file

DDO_Application/Startup.cs

@@ -40,6 +40,7 @@ namespace DDO_Application {
             //services.AddActiveMq("ddoApp-cluster", new[] { ActiveMQ })
             //services.AddActiveMq("ddoApp-cluster", new[] { ActiveMQ })
                     //.AddProducer<MessageProducer>(queue2, RoutingType.Anycast)
                     //.AddProducer<MessageProducer>(queue2, RoutingType.Anycast)
                     //.AddTypedConsumer<TestMessage, TestMessageCunsomer>(queue2, RoutingType.Anycast);
                     //.AddTypedConsumer<TestMessage, TestMessageCunsomer>(queue2, RoutingType.Anycast);
+                    
                     .AddProducer<MessageProducer>(msgQueues.Out, RoutingType.Multicast)
                     .AddProducer<MessageProducer>(msgQueues.Out, RoutingType.Multicast)
                     .AddTypedConsumer<TestMessage, TestMessageCunsomer>(msgQueues.In, RoutingType.Multicast);
                     .AddTypedConsumer<TestMessage, TestMessageCunsomer>(msgQueues.In, RoutingType.Multicast);
             services.AddActiveMqHostedService();
             services.AddActiveMqHostedService();