Commit ac7c30b 1 parent 3e27251 commit ac7c30b Copy full SHA for ac7c30b
File tree 1 file changed +14
-10
lines changed
google-cloud-spanner/src/main/java/com/google/cloud/spanner
1 file changed +14
-10
lines changed Original file line number Diff line number Diff line change @@ -741,7 +741,20 @@ protected SpannerOptions(Builder builder) {
741
741
742
742
transportChannelExecutorThreadNameFormat = builder .transportChannelExecutorThreadNameFormat ;
743
743
channelProvider = builder .channelProvider ;
744
- channelConfigurator = builder .channelConfigurator ;
744
+ if (builder .mTLSContext != null ) {
745
+ channelConfigurator =
746
+ channelBuilder -> {
747
+ if (builder .channelConfigurator != null ) {
748
+ channelBuilder = builder .channelConfigurator .apply (channelBuilder );
749
+ }
750
+ if (channelBuilder instanceof NettyChannelBuilder ) {
751
+ ((NettyChannelBuilder ) channelBuilder ).sslContext (builder .mTLSContext );
752
+ }
753
+ return channelBuilder ;
754
+ };
755
+ } else {
756
+ channelConfigurator = builder .channelConfigurator ;
757
+ }
745
758
interceptorProvider = builder .interceptorProvider ;
746
759
sessionPoolOptions =
747
760
builder .sessionPoolOptions != null
@@ -1620,15 +1633,6 @@ public SpannerOptions build() {
1620
1633
// As we are using plain text, we should never send any credentials.
1621
1634
this .setCredentials (NoCredentials .getInstance ());
1622
1635
}
1623
- if (mTLSContext != null ) {
1624
- this .setChannelConfigurator (
1625
- builder -> {
1626
- if (builder instanceof NettyChannelBuilder ) {
1627
- ((NettyChannelBuilder ) builder ).sslContext (mTLSContext );
1628
- }
1629
- return builder ;
1630
- });
1631
- }
1632
1636
if (this .numChannels == null ) {
1633
1637
this .numChannels =
1634
1638
this .grpcGcpExtensionEnabled ? GRPC_GCP_ENABLED_DEFAULT_CHANNELS : DEFAULT_CHANNELS ;
You can’t perform that action at this time.
0 commit comments