tr

DDO_Application/Controllers/apiController.cs

@@ -44,6 +44,14 @@ namespace DDO_Application.Controllers {
             await _messageProducer.PublishAsync(@event); 
             await _messageProducer.PublishAsync(@event); 
             return StatusCode((int)HttpStatusCode.Created, null);
             return StatusCode((int)HttpStatusCode.Created, null);
         }
         }
+
+        [HttpPost]
+        [Route("[controller]/sendmsg/smev_init")]
+        public async Task<IActionResult> SendInitMessage(string msg) {
+            var @event = new TestMessage { Id = 1, Message = msg };
+            await _messageProducer.PublishAsync(@event);
+            return StatusCode((int)HttpStatusCode.Created, null);
+        }
     }
     }
 
 
     public class apiStatus {
     public class apiStatus {

DDO_Application/Model/ActiveMqExtensions.cs

@@ -9,11 +9,11 @@ using System.Threading.Tasks;
 
 
 namespace DDO_Application.Model {
 namespace DDO_Application.Model {
     public static class ActiveMqExtensions {
     public static class ActiveMqExtensions {
-        public static IActiveMqBuilder AddTypedConsumer<TMessage, TConsumer>(this IActiveMqBuilder builder, RoutingType routingType) where TConsumer : class, ITypedConsumer<TMessage> {
-        //public static IActiveMqBuilder AddTypedConsumer<TMessage, TConsumer>(this IActiveMqBuilder builder, string address, RoutingType routingType) where TConsumer : class, ITypedConsumer<TMessage> {
+        //public static IActiveMqBuilder AddTypedConsumer<TMessage, TConsumer>(this IActiveMqBuilder builder, RoutingType routingType) where TConsumer : class, ITypedConsumer<TMessage> {
+        public static IActiveMqBuilder AddTypedConsumer<TMessage, TConsumer>(this IActiveMqBuilder builder, string address, RoutingType routingType) where TConsumer : class, ITypedConsumer<TMessage> {
             builder.Services.TryAddScoped<TConsumer>();
             builder.Services.TryAddScoped<TConsumer>();
-            builder.AddConsumer(typeof(TMessage).Name, routingType, HandleCustomerMessage<TMessage, TConsumer>);
-            //builder.AddConsumer(address, routingType, HandleCustomerMessage<TMessage, TConsumer>);
+            //builder.AddConsumer(typeof(TMessage).Name, routingType, HandleCustomerMessage<TMessage, TConsumer>);
+            builder.AddConsumer(address, routingType, HandleCustomerMessage<TMessage, TConsumer>);
             return builder;
             return builder;
         }
         }
         private static async Task HandleCustomerMessage<TMessage, TConsumer>(Message message, IConsumer consumer, IServiceProvider serviceProvider, CancellationToken token) where TConsumer : class, ITypedConsumer<TMessage> {
         private static async Task HandleCustomerMessage<TMessage, TConsumer>(Message message, IConsumer consumer, IServiceProvider serviceProvider, CancellationToken token) where TConsumer : class, ITypedConsumer<TMessage> {

DDO_Application/Startup.cs

@@ -40,7 +40,7 @@ namespace DDO_Application {
                     //.AddProducer<MessageProducer>(queue2)
                     //.AddProducer<MessageProducer>(queue2)
                     //.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>(RoutingType.Multicast);
+                    .AddTypedConsumer<TestMessage, TestMessageCunsomer>(msgQueues.In, RoutingType.Multicast);
             services.AddActiveMqHostedService();
             services.AddActiveMqHostedService();
         }
         }