fix tests - if (enqueuedMessage == server.MaxQueueSize)

Author: Maxson-Anjos-MZ

tests/Test.cs

@@ -962,7 +962,7 @@ public void TestConnectSameConnectionMultipleTimes()
             APCIParameters apciParameters = new APCIParameters();
 
             Server server = new Server(apciParameters, parameters);
-
+            int port = GetPort();
             server.SetLocalPort(port);
 
             server.Start();
@@ -1012,7 +1012,7 @@ public void TestConnectSameConnectionMultipleTimesServerDisconnects()
             Server server = new Server(apciParameters, parameters);
 
             server.DebugOutput = true;
-
+            int port = GetPort();
             server.SetLocalPort(port);
 
             server.Start();
@@ -1027,6 +1027,8 @@ public void TestConnectSameConnectionMultipleTimesServerDisconnects()
 
                 connection.Connect();
 
+                Thread.Sleep(1000);
+
                 server.Stop();
 
                 Thread.Sleep(1000);
@@ -3548,7 +3550,7 @@ public void TestSingleRedundancyGroup()
                     Console.WriteLine($"Number of queue entries: {numberOfQueueEntries}");
                     waitTime = 1000;
 
-                    if (enqueuedMessage == server.MaxQueueSize)
+                    if (enqueuedMessage >= server.MaxQueueSize)
                         Assert.AreEqual(server.MaxQueueSize, numberOfQueueEntries);
                     else
                         Assert.AreEqual(enqueuedMessage, numberOfQueueEntries);
@@ -3634,7 +3636,7 @@ public void TestMultipleRedundancyGroup()
                     int numberOfQueueEntries = server.GetNumberOfQueueEntries(redGroup);
                     Console.WriteLine($"Number of queue entries: {numberOfQueueEntries}");
                     waitTime = 1000;
-                    if (enqueuedMessage == server.MaxQueueSize)
+                    if (enqueuedMessage >= server.MaxQueueSize)
                         Assert.AreEqual(server.MaxQueueSize, numberOfQueueEntries);
                     else
                         Assert.AreEqual(enqueuedMessage, numberOfQueueEntries);