Fail with exception on timeout while waiting for connection pool

Author: dennis-sqills

vertx-sql-client/src/main/java/io/vertx/sqlclient/impl/pool/SqlConnectionPool.java

@@ -13,6 +13,7 @@
 
 import io.netty.channel.EventLoop;
 import io.vertx.core.*;
+import io.vertx.core.http.ConnectionPoolTooBusyException;
 import io.vertx.core.impl.ContextInternal;
 import io.vertx.core.impl.EventLoopContext;
 import io.vertx.core.impl.VertxInternal;
@@ -22,6 +23,7 @@
 import io.vertx.core.spi.metrics.ClientMetrics;
 import io.vertx.core.spi.tracing.VertxTracer;
 import io.vertx.core.tracing.TracingPolicy;
+import io.vertx.sqlclient.DatabaseException;
 import io.vertx.sqlclient.SqlConnection;
 import io.vertx.sqlclient.impl.Connection;
 import io.vertx.sqlclient.impl.SqlConnectionBase;
@@ -31,6 +33,7 @@
 import io.vertx.sqlclient.spi.ConnectionFactory;
 import io.vertx.sqlclient.spi.DatabaseMetadata;
 
+import java.sql.SQLTimeoutException;
 import java.util.List;
 import java.util.function.Function;
 import java.util.function.Supplier;
@@ -217,12 +220,10 @@ public void onEnqueue(PoolWaiter<PooledConnection> waiter) {
         if (timeout > 0L && timerID == -1L) {
           timerID = context.setTimer(timeout, id -> {
             pool.cancel(waiter, ar -> {
-              if (ar.succeeded()) {
-                if (ar.result()) {
-                  handler.handle(Future.failedFuture("Timeout"));
-                }
+              if (ar.succeeded() && ar.result()) {
+                handler.handle(Future.failedFuture(new ConnectionPoolTooBusyException("Timeout while waiting for connection")));
               } else {
-                // ????
+                handler.handle(Future.failedFuture(new ConnectionPoolTooBusyException("Failed to cancel pool request after timeout while waiting for connection")));
               }
             });
           });