Skip to content

Commit 0244354

Browse files
committed
Upgrade to SslContextManager/SslContextProvider changes
1 parent 72ed6a1 commit 0244354

File tree

2 files changed

+9
-7
lines changed

2 files changed

+9
-7
lines changed

vertx-mssql-client/src/main/java/io/vertx/mssqlclient/impl/MSSQLConnectionFactory.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import io.vertx.core.internal.ContextInternal;
1818
import io.vertx.core.internal.VertxInternal;
1919
import io.vertx.core.internal.net.NetSocketInternal;
20+
import io.vertx.core.internal.tls.ClientSslContextManager;
2021
import io.vertx.core.internal.tls.SslContextManager;
2122
import io.vertx.core.net.HostAndPort;
2223
import io.vertx.core.net.NetClientOptions;
@@ -34,15 +35,15 @@
3435

3536
public class MSSQLConnectionFactory extends ConnectionFactoryBase<MSSQLConnectOptions> {
3637

37-
private final SslContextManager sslContextManager;
38+
private final ClientSslContextManager sslContextManager;
3839

3940
public MSSQLConnectionFactory(VertxInternal vertx) {
4041
this(vertx, new NetClientOptions());
4142
}
4243

4344
public MSSQLConnectionFactory(VertxInternal vertx, NetClientOptions transportOptions) {
4445
super(vertx, transportOptions);
45-
sslContextManager = new SslContextManager(SslContextManager.resolveEngineOptions(tcpOptions.getSslEngineOptions(), tcpOptions.isUseAlpn()));
46+
sslContextManager = new ClientSslContextManager(SslContextManager.resolveEngineOptions(tcpOptions.getSslEngineOptions(), tcpOptions.isUseAlpn()));
4647
}
4748

4849
@Override

vertx-mssql-client/src/main/java/io/vertx/mssqlclient/impl/MSSQLSocketConnection.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import io.vertx.core.internal.net.NetSocketInternal;
2222
import io.vertx.core.internal.net.SslChannelProvider;
2323
import io.vertx.core.internal.net.SslHandshakeCompletionHandler;
24+
import io.vertx.core.internal.tls.ClientSslContextManager;
2425
import io.vertx.core.internal.tls.SslContextManager;
2526
import io.vertx.core.net.ClientSSLOptions;
2627
import io.vertx.core.net.HostAndPort;
@@ -47,13 +48,13 @@
4748
public class MSSQLSocketConnection extends SocketConnectionBase {
4849

4950
private final MSSQLConnectOptions connectOptions;
50-
private final SslContextManager SslContextManager;
51+
private final ClientSslContextManager sslContextManager;
5152

5253
private MSSQLDatabaseMetadata databaseMetadata;
5354
private HostAndPort alternateServer;
5455

5556
MSSQLSocketConnection(NetSocketInternal socket,
56-
SslContextManager SslContextManager,
57+
ClientSslContextManager SslContextManager,
5758
ClientMetrics clientMetrics,
5859
MSSQLConnectOptions connectOptions,
5960
boolean cachePreparedStatements,
@@ -63,7 +64,7 @@ public class MSSQLSocketConnection extends SocketConnectionBase {
6364
ContextInternal context) {
6465
super(socket, clientMetrics, cachePreparedStatements, preparedStatementCacheSize, preparedStatementCacheSqlFilter, pipeliningLimit, context);
6566
this.connectOptions = connectOptions;
66-
this.SslContextManager = SslContextManager;
67+
this.sslContextManager = SslContextManager;
6768
}
6869

6970
@Override
@@ -110,8 +111,8 @@ Future<Void> enableSsl(boolean clientConfigSsl, byte encryptionLevel, MSSQLConne
110111

111112
// 2. Create and set up an SSLHelper and SSLHandler
112113
// options.getApplicationLayerProtocols()
113-
Future<SslChannelProvider> f = SslContextManager
114-
.resolveSslContextProvider(sslOptions, "", null, context)
114+
Future<SslChannelProvider> f = sslContextManager
115+
.resolveSslContextProvider(sslOptions, context)
115116
.map(provider -> new SslChannelProvider(context.owner(), provider, false));
116117
return f.compose(provider -> {
117118
SocketAddress socketAddress = socket.remoteAddress();

0 commit comments

Comments
 (0)