We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6e399a2 commit cdfe779Copy full SHA for cdfe779
vertx-sql-client/src/main/java/io/vertx/sqlclient/impl/PoolImpl.java
@@ -169,7 +169,9 @@ public Future<SqlConnection> getConnection() {
169
170
@Override
171
public <R> Future<R> schedule(ContextInternal context, CommandBase<R> cmd) {
172
- return pool.execute(context, cmd);
+ PromiseInternal<SqlConnectionPool.PooledConnection> promise = context.promise();
173
+ acquire(context, connectionTimeout, promise);
174
+ return promise.future().compose((pooled -> pooled.schedule(context, cmd)));
175
}
176
177
private void acquire(ContextInternal context, long timeout, Handler<AsyncResult<SqlConnectionPool.PooledConnection>> completionHandler) {
0 commit comments