spring/spring-boot
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-boot.git synced 2026-09-17 12:09:16 +00:00
Code Issues Projects Releases Wiki Activity

Improve null-safety of module/spring-boot-kafka

Browse Source 
See gh-46926
This commit is contained in:
Moritz Halbritter
2025-08-26 14:22:55 +02:00
parent 9d1b4897f1
commit 369b1e92f9
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
module/spring-boot-kafka/src/main/java/org/springframework/boot/kafka/autoconfigure/SslBundleSslEngineFactory.java
+12 -8
View File
@@ -59,8 +59,9 @@ public class SslBundleSslEngineFactory implements SslEngineFactory {
@Override
public SSLEngine createClientSslEngine(String peerHost, int peerPort, String endpointIdentification) {
Assert.state(this.sslBundle != null, "'sslBundle' must not be null");
SSLEngine sslEngine = this.sslBundle.createSslContext().createSSLEngine(peerHost, peerPort);
SslBundle sslBundle = this.sslBundle;
Assert.state(sslBundle != null, "'sslBundle' must not be null");
SSLEngine sslEngine = sslBundle.createSslContext().createSSLEngine(peerHost, peerPort);
sslEngine.setUseClientMode(true);
SSLParameters sslParams = sslEngine.getSSLParameters();
sslParams.setEndpointIdentificationAlgorithm(endpointIdentification);
@@ -70,8 +71,9 @@ public class SslBundleSslEngineFactory implements SslEngineFactory {
@Override
public SSLEngine createServerSslEngine(String peerHost, int peerPort) {
Assert.state(this.sslBundle != null, "'sslBundle' must not be null");
SSLEngine sslEngine = this.sslBundle.createSslContext().createSSLEngine(peerHost, peerPort);
SslBundle sslBundle = this.sslBundle;
Assert.state(sslBundle != null, "'sslBundle' must not be null");
SSLEngine sslEngine = sslBundle.createSslContext().createSSLEngine(peerHost, peerPort);
sslEngine.setUseClientMode(false);
return sslEngine;
}
@@ -88,14 +90,16 @@ public class SslBundleSslEngineFactory implements SslEngineFactory {
@Override
public @Nullable KeyStore keystore() {
Assert.state(this.sslBundle != null, "'sslBundle' must not be null");
return this.sslBundle.getStores().getKeyStore();
SslBundle sslBundle = this.sslBundle;
Assert.state(sslBundle != null, "'sslBundle' must not be null");
return sslBundle.getStores().getKeyStore();
}
@Override
public @Nullable KeyStore truststore() {
Assert.state(this.sslBundle != null, "'sslBundle' must not be null");
return this.sslBundle.getStores().getTrustStore();
SslBundle sslBundle = this.sslBundle;
Assert.state(sslBundle != null, "'sslBundle' must not be null");
return sslBundle.getStores().getTrustStore();
}
}