config added

DDO_Application/Model/MessageCunsomer.cs

@@ -12,7 +12,8 @@ namespace DDO_Application.Model {
         }
         public async Task ConsumeAsync(ReceivedMessage message, CancellationToken cancellationToken) {
             
-            
+            // тут логика
+
             Console.WriteLine(message);
         }
     }

DDO_Application/Model/MessageProducer.cs

@@ -5,15 +5,19 @@ using System.Threading.Tasks;
 namespace DDO_Application.Model {
     public class MessageProducer {
         private readonly IAnonymousProducer _producer;
+        private readonly string _address;
         public MessageProducer(IAnonymousProducer producer) {
             _producer = producer;
+            _address = "test";
+        }
+        public MessageProducer(IAnonymousProducer producer, string address) {
+            _producer = producer;
+            _address = address;
         }
-
         public async Task PublishAsync<T>(T message) {
             var serialized = JsonSerializer.Serialize(message);
-            var address = "test";
             var msg = new Message(serialized);
-            await _producer.SendAsync(address, msg);
+            await _producer.SendAsync(_address, msg);
         }
     }
 }

DDO_Application/Model/configActiveMQ.cs → DDO_Application/Model/config.cs

@@ -12,4 +12,9 @@ namespace DDO_Application.Model {
 
         public Endpoint Endpoint => Endpoint.Create(Host, Port, User, Pass);
     }
+
+    public class configTestQueues {
+        public string In { get; set; }
+        public string Out { get; set; }
+    }
 }

DDO_Application/Startup.cs

@@ -29,6 +29,7 @@ namespace DDO_Application {
         public void ConfigureServices(IServiceCollection services) {
 
             var ActiveMQ = Configuration.GetSection("ActiveMQ").Get<configActiveMQ>().Endpoint;
+            var testQueue = Configuration.GetSection("TestQueues").Get<configTestQueues>();
 
             services.AddControllers();
             services.AddSwaggerGen(c => {c.SwaggerDoc("v1", new OpenApiInfo { Title = "DDO_Application", Version = "v1" }); });
@@ -38,11 +39,8 @@ namespace DDO_Application {
             //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "192.168.2.19", port: 5672, "guest", "guest") })
             services.AddActiveMq("ddoApp-cluster", new[] { ActiveMQ })
                     .AddAnonymousProducer<MessageProducer>()
+                    //.AddProducer<MessageProducer>(testQueue.Out, RoutingType.Multicast)
                     .AddTypedConsumer<ReceivedMessage, MessageCunsomer>(RoutingType.Multicast);
-            //.AddConsumer("test", RoutingType.Multicast, async (message, consumer, serviceProvider, cancellationToken) => {
-            //    // your consuming logic
-            //    await consumer.AcceptAsync(message);
-            //});
             services.AddActiveMqHostedService();
 
 

DDO_Application/appsettings.json

@@ -5,6 +5,10 @@
     "User": "guest",
     "Pass": "guest"
   },
+  "TestQueues": {
+    "In": "test",
+    "Out": "test"
+  },
 
   "Logging": {
     "LogLevel": {