From e325b9958e1a08914f24371bb8f0b2e262471ba9 Mon Sep 17 00:00:00 2001 From: Anmol Vijaywargiya Date: Thu, 15 Sep 2022 13:57:42 +0530 Subject: [PATCH] Add log for subscriber info once the state has started completely --- src/ziggurat/messaging/consumer.clj | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/ziggurat/messaging/consumer.clj b/src/ziggurat/messaging/consumer.clj index 1f8c348e..5a32b9ac 100644 --- a/src/ziggurat/messaging/consumer.clj +++ b/src/ziggurat/messaging/consumer.clj @@ -196,7 +196,8 @@ handler (-> batch-route second :handler-fn) retry-subscribers (start-retry-subscriber* (fn [message] (ch/process handler message)) topic-entity)] (assoc subscriber-map topic-entity {:retry retry-subscribers}))) {} batch-routes) - data {:stream-consumers stream-consumers :batch-consumers batch-consumers}] + data {:stream-consumers stream-consumers :batch-consumers batch-consumers} + _ (log/info "Subscriber info" data)] data))) (defn stop-subscribers [subscribers additional-message]