Commit d09d1666 by AlexNasyr

xml tested

parent 79f0f267
...@@ -16,7 +16,7 @@ namespace SocialMinistryDataExchange.Controllers { ...@@ -16,7 +16,7 @@ namespace SocialMinistryDataExchange.Controllers {
_messageProducer = messageProducer; _messageProducer = messageProducer;
} }
//тестовый запрос для симуляции получения XML запроса //тестовый запрос для симуляции получения XML запроса (берется из файла)
[HttpGet] [HttpGet]
[Route("[controller]/putXMLDefenceStatus")] [Route("[controller]/putXMLDefenceStatus")]
public async Task<string> PutXMLDefenceStatus() { public async Task<string> PutXMLDefenceStatus() {
...@@ -25,12 +25,13 @@ namespace SocialMinistryDataExchange.Controllers { ...@@ -25,12 +25,13 @@ namespace SocialMinistryDataExchange.Controllers {
return responce; return responce;
} }
//тестовый запрос для симуляции получения XML запроса //тестовый запрос для отправки XML запроса во входящую очередь (типа они отправили)
[HttpGet] [HttpGet]
[Route("[controller]/putXMLToActiveMQServer")] [Route("[controller]/putXMLToActiveMQServer")]
public async Task<IActionResult> PutXMLToAMQ() { public async Task<IActionResult> PutXMLToAMQ() {
var request = System.IO.File.ReadAllText("Model/reference/Request.xml"); var request = System.IO.File.ReadAllText("Model/reference/Request.xml");
await _messageProducer.PublishAsync(request); await _messageProducer.PublishAsync(request);
return StatusCode((int)HttpStatusCode.Created, null); return StatusCode((int)HttpStatusCode.Created, null);
} }
......
using ActiveMQ.Artemis.Client; using ActiveMQ.Artemis.Client;
using SocialMinistryDataExchange.Model.EscpSD;
using System; using System;
using System.IO;
using System.Threading.Tasks; using System.Threading.Tasks;
using System.Xml.Serialization;
namespace SocialMinistryDataExchange.Model { namespace SocialMinistryDataExchange.Model {
public class MessageProducer { public class MessageProducer {
...@@ -13,15 +10,7 @@ namespace SocialMinistryDataExchange.Model { ...@@ -13,15 +10,7 @@ namespace SocialMinistryDataExchange.Model {
_producer = producer; _producer = producer;
} }
public async Task PublishAsync<T>(T message) { public async Task PublishAsync<T>(T message) {
XmlSerializer xmlSerializer = new(typeof(EcspSendingStatusMaloimushch)); var msg = new Message(message);
string serialized = message.ToString();
//string serialized = string.Empty;
//using (StringWriter writer = new()) {
// xmlSerializer.Serialize(writer, message);
// serialized = writer.ToString();
//}
var msg = new Message(serialized);
try { try {
await _producer.SendAsync(msg); await _producer.SendAsync(msg);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment