Skip to content

Commit

Permalink
Add log for subscriber info once the state has started completely
Browse files Browse the repository at this point in the history
  • Loading branch information
Anmol Vijaywargiya committed Sep 15, 2022
1 parent 3b49d98 commit e325b99
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/ziggurat/messaging/consumer.clj
Original file line number Diff line number Diff line change
Expand Up @@ -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]
Expand Down

0 comments on commit e325b99

Please sign in to comment.