From f30104ef8d14d345095ea1f3dbe2d114a1de68cd Mon Sep 17 00:00:00 2001 From: Anmol Vijaywargiya Date: Wed, 14 Sep 2022 13:17:44 +0530 Subject: [PATCH] Check whether consumers state is a map before stopping it --- src/ziggurat/messaging/consumer.clj | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/ziggurat/messaging/consumer.clj b/src/ziggurat/messaging/consumer.clj index 9da59d31..a5d48c62 100644 --- 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))))))