From c15bd97c9780e58a2d23319f4a9334a43d65cf81 Mon Sep 17 00:00:00 2001
From: Matt Fleming <matt@codeblueprint.co.uk>
Date: Mon, 8 Nov 2021 17:10:18 +0000
Subject: [PATCH] Avoid NullPointerException if pulsarCache hasn't been
 initialized.

---
 .../main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java
index 630810b43..2039e60a0 100644
--- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java
+++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java
@@ -78,6 +78,10 @@ public class PulsarActivity extends SimpleActivity implements ActivityDefObserve
     public void shutdownActivity() {
         super.shutdownActivity();
 
+        if (pulsarCache == null) {
+            return;
+        }
+
         for (PulsarSpace pulsarSpace : pulsarCache.getAssociatedPulsarSpace()) {
             pulsarSpace.shutdownPulsarSpace();
         }