ddo - msg broker string message added

DDO_Application/Controllers/apiController.cs

@@ -54,7 +54,7 @@ namespace DDO_Application.Controllers {
         [HttpPost]
         [HttpPost]
         [Route("[controller]/sendmsg/{msg}")]
         [Route("[controller]/sendmsg/{msg}")]
         public async Task<IActionResult> SendMessage(string msg) {
         public async Task<IActionResult> SendMessage(string msg) {
-            var @event = new TestMessage { businessId = "1", Message = msg};
+            var @event = new TestMessage { businessId = "e6c77d95-54a7-4645-818b-16fd71322b6e", Message = msg};
             await _messageProducer.PublishAsync(@event); 
             await _messageProducer.PublishAsync(@event); 
             return StatusCode((int)HttpStatusCode.Created, null);
             return StatusCode((int)HttpStatusCode.Created, null);
         }
         }
@@ -62,7 +62,14 @@ namespace DDO_Application.Controllers {
         [HttpPost]
         [HttpPost]
         [Route("[controller]/sendmsg/smev_init")]
         [Route("[controller]/sendmsg/smev_init")]
         public async Task<IActionResult> SendInitMessage() {
         public async Task<IActionResult> SendInitMessage() {
-            var @event = new TestMessage { businessId = GUID, Message = @"<?xml version=""1.0"" encoding=""UTF-8""?><xsd:schema xmlns:xsd=""http://www.w3.org/2001/XMLSchema"" xmlns:tns=""http://epgu.gosuslugi.ru/concentrator/kindergarten/3.2.1"" targetNamespace=""http://epgu.gosuslugi.ru/concentrator/kindergarten/3.2.1"" elementFormDefault=""qualified"" attributeFormDefault=""unqualified""></xsd:schema>" };
+            //var @event = new TestMessage { businessId = GUID, Message = @"<?xml version=""1.0"" encoding=""UTF-8""?><xsd:schema xmlns:xsd=""http://www.w3.org/2001/XMLSchema"" xmlns:tns=""http://epgu.gosuslugi.ru/concentrator/kindergarten/3.2.1"" targetNamespace=""http://epgu.gosuslugi.ru/concentrator/kindergarten/3.2.1"" elementFormDefault=""qualified"" attributeFormDefault=""unqualified""></xsd:schema>" };
+            //var @event = @"<?xml version=""1.0"" encoding=""utf-8""?>
+            //             <ns:FormData oktmo=""00000000000"" xmlns: ns=""http://epgu.gosuslugi.ru/concentrator/kindergarten/3.2.1"">
+            //             <ns:ApplicationRequest>
+            //             <ns:TestData>Blah-Blah</ns:TestData>
+            //             </ns:ApplicationRequest>
+            //             </ns:FormData>";
+            var @event = "Hello, bliya!";
             await _messageProducer.PublishAsync(@event);
             await _messageProducer.PublishAsync(@event);
             return StatusCode((int)HttpStatusCode.Created, null);
             return StatusCode((int)HttpStatusCode.Created, null);
         }
         }

DDO_Application/Model/TestMessageCunsomer.cs → DDO_Application/Model/MessageCunsomers.cs

@@ -4,15 +4,21 @@ using System.Threading.Tasks;
 
 
 namespace DDO_Application.Model {
 namespace DDO_Application.Model {
     public class TestMessageCunsomer : ITypedConsumer<TestMessage> {
     public class TestMessageCunsomer : ITypedConsumer<TestMessage> {
-
         public TestMessageCunsomer() {
         public TestMessageCunsomer() {
-
         }
         }
         public async Task ConsumeAsync(TestMessage message, CancellationToken cancellationToken) {
         public async Task ConsumeAsync(TestMessage message, CancellationToken cancellationToken) {
-            
             // тут логика
             // тут логика
+            Console.WriteLine(message);
+        }
+    }
 
 
+    public class StringMessageCunsomer : ITypedConsumer<String> {
+        public StringMessageCunsomer() {
+        }
+        public async Task ConsumeAsync(String message, CancellationToken cancellationToken) {
+            // тут логика
             Console.WriteLine(message);
             Console.WriteLine(message);
         }
         }
     }
     }
+
 }
 }

DDO_Application/Model/MessageProducer.cs

 using ActiveMQ.Artemis.Client;
 using ActiveMQ.Artemis.Client;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Configuration;
+using System;
 using System.Text.Json;
 using System.Text.Json;
 using System.Threading.Tasks;
 using System.Threading.Tasks;
 
 
@@ -14,11 +15,14 @@ namespace DDO_Application.Model {
             var serialized = JsonSerializer.Serialize(message);
             var serialized = JsonSerializer.Serialize(message);
 
 
             var msg = new Message(serialized) {
             var msg = new Message(serialized) {
-                MessageId = "e6c77d95-54a7-4645-818b-16fd71322b6e"
+                //businessId = "e6c77d95-54a7-4645-818b-16fd71322b6e"
             };
             };
 
 
+            try {
                 await _producer.SendAsync(msg);
                 await _producer.SendAsync(msg);
-
+            }
+            catch (Exception ex) { 
+            }
 
 
         }
         }
     }
     }

DDO_Application/Startup.cs

@@ -43,7 +43,9 @@ namespace DDO_Application {
                 //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "192.168.2.22", port: 5672, "admin", "admin") })
                 //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "192.168.2.22", port: 5672, "admin", "admin") })
                 //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)
+                        .AddTypedConsumer<String, StringMessageCunsomer>(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);

SocialMinistryDataExchange/Model/SMRepository.cs

@@ -32,6 +32,8 @@ namespace SocialMinistryDataExchange.Model {
             using (StringWriter writer = new()) {
             using (StringWriter writer = new()) {
                 xmlSerializer.Serialize(writer, request);
                 xmlSerializer.Serialize(writer, request);
                 responce = writer.ToString();
                 responce = writer.ToString();
+
+
             }
             }
             return Task.FromResult(responce);
             return Task.FromResult(responce);
         }
         }