Introduce non-existing host resolving timeout

sanych-sun · Mar 6, 2024 · b105625 · b105625
1 parent 8cc43f0
commit b105625
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/RabbitMQ.Next/Sockets/EndpointResolver.cs b/src/RabbitMQ.Next/Sockets/EndpointResolver.cs
@@ -8,13 +8,15 @@
 using System.Threading;
 using System.Threading.Tasks;
 using RabbitMQ.Next.Exceptions;
+using RabbitMQ.Next.Tasks;
 
 namespace RabbitMQ.Next.Sockets;
 
 internal static class EndpointResolver
 {
     public static async Task<ISocket> OpenSocketAsync(IReadOnlyList<Endpoint> endpoints, CancellationToken cancellation)
     {
+        cancellation = new CancellationTokenSource(TimeSpan.FromSeconds(10)).Token.Combine(cancellation);
         Dictionary<Uri, Exception> exceptions = null;
 
         foreach (var endpoint in endpoints)