tests about addresses

DDO_Application/Controllers/apiController.cs

@@ -44,6 +44,13 @@ 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]/sendanothermsg/{msg}")]
+        public async Task<IActionResult> SendAnotherMessage(string msg) {
+            var @event = new OneMoreTestMessage { Id = 2, Message = msg };
+            await _messageProducer.PublishAsync(@event);
+            return StatusCode((int)HttpStatusCode.Created, null);
+        }
     }
     }
 
 
     public class apiStatus {
     public class apiStatus {

DDO_Application/Model/ActiveMqExtensions.cs

@@ -9,9 +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, string address, RoutingType routingType) where TConsumer : class, ITypedConsumer<TMessage> {
-            builder.Services.TryAddScoped<TConsumer>();
-            builder.AddConsumer(address, routingType, HandleCustomerMessage<TMessage, TConsumer>);
+        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.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/Model/MessageCunsomer.cs → DDO_Application/Model/TestMessageCunsomer.cs

@@ -3,9 +3,9 @@ using System.Threading;
 using System.Threading.Tasks;
 using System.Threading.Tasks;
 
 
 namespace DDO_Application.Model {
 namespace DDO_Application.Model {
-    public class MessageCunsomer : ITypedConsumer<TestMessage> {
+    public class TestMessageCunsomer : ITypedConsumer<TestMessage> {
 
 
-        public MessageCunsomer() {
+        public TestMessageCunsomer() {
 
 
         }
         }
         public async Task ConsumeAsync(TestMessage message, CancellationToken cancellationToken) {
         public async Task ConsumeAsync(TestMessage message, CancellationToken cancellationToken) {

DDO_Application/Startup.cs

@@ -34,13 +34,13 @@ namespace DDO_Application {
             services.AddHostedService<ApiHostedService>();
             services.AddHostedService<ApiHostedService>();
             services.AddSingleton<IApiService, ApiProcessingService>();
             services.AddSingleton<IApiService, ApiProcessingService>();
             // turn enable ActiveMQ support in project
             // turn enable ActiveMQ support in project
-            services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "172.17.100.121", port: 61616, "contingent", "RjQ66VWS") })
+            //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "172.17.100.121", port: 61616, "contingent", "RjQ66VWS") })
             //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "192.168.2.19", port: 5672, "guest", "guest") })
             //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "192.168.2.19", port: 5672, "guest", "guest") })
-            //services.AddActiveMq("ddoApp-cluster", new[] { ActiveMQ })
-                    .AddProducer<MessageProducer>(queue2)
-                    .AddTypedConsumer<TestMessage, MessageCunsomer>(queue2, RoutingType.Anycast);
-                    //.AddProducer<MessageProducer>(msgQueues.Out)
-                    //.AddTypedConsumer<TestMessage, MessageCunsomer>(msgQueues.In, RoutingType.Multicast);
+            services.AddActiveMq("ddoApp-cluster", new[] { ActiveMQ })
+                    //.AddProducer<MessageProducer>(queue2)
+                    //.AddTypedConsumer<TestMessage, TestMessageCunsomer>(queue2, RoutingType.Anycast);
+                    .AddProducer<MessageProducer>(msgQueues.Out, RoutingType.Multicast)
+                    .AddTypedConsumer<TestMessage, TestMessageCunsomer>(RoutingType.Multicast);
             services.AddActiveMqHostedService();
             services.AddActiveMqHostedService();
         }
         }
 
 

DDO_Application/appsettings.json

@@ -6,8 +6,8 @@
     "Pass": "guest"
     "Pass": "guest"
   },
   },
   "TestQueues": {
   "TestQueues": {
-    "In": "test",
-    "Out": "test"
+    "In": "TestMessage",
+    "Out": "TestMessage"
   },
   },
 
 
   "Logging": {
   "Logging": {