diff --git a/Microservicios/MsUsuarios/Models/RabbitMQConfig.cs b/Microservicios/MsUsuarios/Models/RabbitMQConfig.cs index dedd8df..39ffa47 100644 --- a/Microservicios/MsUsuarios/Models/RabbitMQConfig.cs +++ b/Microservicios/MsUsuarios/Models/RabbitMQConfig.cs @@ -7,13 +7,16 @@ namespace MSAdminUsuarios.Models public string HostName { get; set; } = null!; public string UserName { get; set; } = null!; public string Password { get; set; } = null!; + public int Port { get; set; } public override string ToString() { - if(Debugger.IsAttached) { + if (Debugger.IsAttached) + { return ($"HostName: {HostName},\n " + $"UserName: {UserName},\n" + - $"Password: {Password}"); + $"Password: {Password},\n" + + $"Port: {Port}"); } return ""; } diff --git a/Microservicios/MsUsuarios/Program.cs b/Microservicios/MsUsuarios/Program.cs index 87a1ab7..6f94a7b 100644 --- a/Microservicios/MsUsuarios/Program.cs +++ b/Microservicios/MsUsuarios/Program.cs @@ -67,7 +67,8 @@ builder.Services.AddSingleton(sp => { HostName = config.HostName, UserName = config.UserName, - Password = config.Password + Password = config.Password, + Port = config.Port, }; return factory.CreateConnection(); }); @@ -125,6 +126,11 @@ app.MapControllers(); #endregion +using (var scope = app.Services.CreateScope()) +{ + // Inicializar el canal - Crea lo necesario en Rabbit antes de subscribirse + var channel = scope.ServiceProvider.GetRequiredService(); +} // Start and Subscribe to RabbitMQ event RabbitMQService.ListenForIntegrationEvents(projectName, builder); diff --git a/Microservicios/MsUsuarios/Utils/RabbitMQService.cs b/Microservicios/MsUsuarios/Utils/RabbitMQService.cs index 947c61e..eb42176 100644 --- a/Microservicios/MsUsuarios/Utils/RabbitMQService.cs +++ b/Microservicios/MsUsuarios/Utils/RabbitMQService.cs @@ -20,10 +20,13 @@ namespace MSAdminUsuarios.Utils public readonly struct MQueues { - public static readonly string medico = "UsuarioMedico"; + //AdminUsuarios public static readonly string PerfilesPorUsuario = "PerfilesPorUsuario"; public static readonly string Usuarios = "Usuarios"; + + // Agenda public static readonly string FirmaUsuario = $"{Usuarios}.Firma"; + public static readonly string medico = "UsuarioMedico"; } public class MsComunicadoresModel @@ -114,6 +117,7 @@ namespace MSAdminUsuarios.Utils HostName = mqConfig.HostName, UserName = mqConfig.UserName, Password = mqConfig.Password, + Port = mqConfig.Port }; IConnection connection = factory.CreateConnection(); diff --git a/Microservicios/MsUsuarios/appsettings.Development.json b/Microservicios/MsUsuarios/appsettings.Development.json index 29aae31..a707b95 100644 --- a/Microservicios/MsUsuarios/appsettings.Development.json +++ b/Microservicios/MsUsuarios/appsettings.Development.json @@ -2,10 +2,11 @@ "ConnectionStrings": { "ConString": "user id=ADMIN;password=ITTASA2017;data source=(DESCRIPTION=(ADDRESS=(PROTOCOL=tcp)(HOST=181.204.191.98)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=PROYECTOS)))" }, - "RabbitMQConfig": { + "RabbitMQConfig": { "HostName": "localhost", "UserName": "guest", - "Password": "guest" + "Password": "guest", + "Port": 5672 }, "Logging": { "LogLevel": { diff --git a/Microservicios/MsUsuarios/appsettings.json b/Microservicios/MsUsuarios/appsettings.json index 0a1797c..37d6c45 100644 --- a/Microservicios/MsUsuarios/appsettings.json +++ b/Microservicios/MsUsuarios/appsettings.json @@ -5,7 +5,8 @@ "RabbitMQConfig": { "HostName": "localhost", "UserName": "guest", - "Password": "guest" + "Password": "guest", + "Port": 5672 }, "Logging": { "LogLevel": {