Check whether consumers state is a map before stopping it

gojek · Sep 14, 2022 · f30104e · f30104e
1 parent 2e06282
commit f30104e
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/ziggurat/messaging/consumer.clj b/src/ziggurat/messaging/consumer.clj
@@ -207,8 +207,9 @@
            (start-subscribers (:stream-routes (mount.core/args)) (:batch-routes (mount.core/args))))
   :stop (do
           (log/info "Stopping rabbitmq consumers")
-          (when (contains? consumers :stream-consumers)
-            (stop-subscribers-for-consumers (:rabbitmq-channel consumers) (:stream-consumers consumers)))
-          (when (contains? consumers :batch-consumers)
-            (stop-subscribers-for-consumers (:rabbitmq-channel consumers) (:batch-consumers consumers)))))
+          (when (map? consumers)
+            (when (contains? consumers :stream-consumers)
+              (stop-subscribers-for-consumers (:rabbitmq-channel consumers) (:stream-consumers consumers)))
+            (when (contains? consumers :batch-consumers)
+              (stop-subscribers-for-consumers (:rabbitmq-channel consumers) (:batch-consumers consumers))))))