Skip to content

Commit f45ecf7

Browse files
committed
Avoid using impl ConnectionBase
1 parent 4c843d3 commit f45ecf7

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,11 +13,11 @@
1313

1414
import io.netty.channel.EventLoop;
1515
import io.vertx.core.*;
16+
import io.vertx.core.internal.net.NetSocketInternal;
1617
import io.vertx.core.net.SocketAddress;
1718
import io.vertx.core.spi.metrics.ClientMetrics;
1819
import io.vertx.core.spi.tracing.VertxTracer;
1920
import io.vertx.core.tracing.TracingPolicy;
20-
import io.vertx.core.net.impl.ConnectionBase;
2121
import io.vertx.core.internal.pool.*;
2222
import io.vertx.core.internal.ContextInternal;
2323
import io.vertx.core.internal.VertxInternal;
@@ -123,7 +123,7 @@ public Future<ConnectResult<PooledConnection>> connect(ContextInternal context,
123123
return Future.succeededFuture(new ConnectResult<>(pooled, pipelined ? conn.pipeliningLimit() : 1, 0));
124124
}
125125
} else {
126-
return Future.failedFuture(ConnectionBase.CLOSED_EXCEPTION);
126+
return Future.failedFuture(NetSocketInternal.CLOSED_EXCEPTION);
127127
}
128128
});
129129
}
@@ -414,7 +414,7 @@ public void handleClosed() {
414414
Promise<ConnectResult<PooledConnection>> resultHandler = poolCallback;
415415
if (resultHandler != null) {
416416
poolCallback = null;
417-
resultHandler.fail(ConnectionBase.CLOSED_EXCEPTION);
417+
resultHandler.fail(NetSocketInternal.CLOSED_EXCEPTION);
418418
}
419419
listener.onRemove();
420420
}

0 commit comments

Comments
 (0)