Innovenergy
/
Innovenergy_trunk
2
1
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Put try-catch statement when trying to connect to the queue for the first time

This commit is contained in:
Noe 2023-11-06 14:29:04 +01:00
parent 30a3a05de0
commit 511c3080a6
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
csharp/App/SaliMax/src/Program.cs
View File

@ -298,14 +298,21 @@ internal static class Program
private static void SubscribeToQueue(SalimaxAlarmState currentSalimaxState, String? s3Bucket) private static void SubscribeToQueue(SalimaxAlarmState currentSalimaxState, String? s3Bucket)
{ {
_factory = new ConnectionFactory { HostName = VpnServerIp }; try
_connection = _factory.CreateConnection(); {
_channel = _connection.CreateModel(); _factory = new ConnectionFactory { HostName = VpnServerIp };
_channel.QueueDeclare(queue: "statusQueue", durable: false, exclusive: false, autoDelete: false, arguments: null); _connection = _factory.CreateConnection();
Console.WriteLine("The controller sends its status to the middleware for the first time"); _channel = _connection.CreateModel();
if (s3Bucket != null) InformMiddleware(s3Bucket, (Int32)currentSalimaxState); _channel.QueueDeclare(queue: "statusQueue", durable: false, exclusive: false, autoDelete: false, arguments: null);
Console.WriteLine("The controller sends its status to the middleware for the first time");
if (s3Bucket != null) InformMiddleware(s3Bucket, (Int32)currentSalimaxState);
_subscribedToQueue = true; _subscribedToQueue = true;
}
catch (Exception ex)
{
Console.WriteLine("An error occurred while connecting to the RabbitMQ queue: " + ex.Message);
}
} }
private static IPAddress FindVpnIp() private static IPAddress FindVpnIp()