From d296e6862a69d06d42a42443df44e027dc453ad2 Mon Sep 17 00:00:00 2001
From: Chris Bono <cbono@vmware.com>
Date: Wed, 13 Dec 2023 21:45:06 -0600
Subject: [PATCH] Close cache safely in DefaultReactivePulsarSenderFactory
 close() (#519)

Fixes https://github.com/spring-projects/spring-boot/issues/38161
---
 .../reactive/core/DefaultReactivePulsarSenderFactory.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 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
index 4214b148..a7f660c4 100644
--- 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);