Close cache safely in DefaultReactivePulsarSenderFactory close() (#519)

Fixes https://github.com/spring-projects/spring-boot/issues/38161
2023-12-13 21:45:06 -06:00
parent 66a75d1e26
commit d296e6862a
1 changed files with 3 additions and 2 deletions
--- a/spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/core/DefaultReactivePulsarSenderFactory.java
+++ b/spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/core/DefaultReactivePulsarSenderFactory.java
@@ -172,8 +172,9 @@ public final class DefaultReactivePulsarSenderFactory<T>
 	@Override
 	public void doStop() {
 		try {
-			this.reactiveMessageSenderCache.close();
-
+			if (this.reactiveMessageSenderCache != null) {
+				this.reactiveMessageSenderCache.close();
+			}
 		}
 		catch (Exception e) {
 			throw new RuntimeException(e);