using channel-retry-count method from ziggurat.config

gojek · Jul 6, 2022 · 165e29c · 165e29c
1 parent 1250fec
commit 165e29c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/ziggurat/config.clj b/src/ziggurat/config.clj
@@ -260,3 +260,6 @@
 
 (defn get-configured-retry-count []
   (-> (ziggurat-config) :retry :count))
+
+(defn get-channel-retry-count [topic-entity channel]
+  (:count (channel-retry-config topic-entity channel)))
diff --git a/src/ziggurat/mapper.clj b/src/ziggurat/mapper.clj
@@ -1,7 +1,7 @@
 (ns ziggurat.mapper
   (:require [clojure.string :as str]
             [sentry-clj.async :as sentry]
-            [ziggurat.config :refer [ziggurat-config get-configured-retry-count]]
+            [ziggurat.config :refer [ziggurat-config get-configured-retry-count get-channel-retry-count]]
             [ziggurat.messaging.producer :as producer]
             [ziggurat.metrics :as metrics]
             [ziggurat.new-relic :as nr]
@@ -83,7 +83,7 @@
           failure-metric "failure"
           dead-letter-metric "dead-letter"
           multi-message-processing-namespaces [message-processing-namespaces [message-processing-namespace]]
-          user-payload (create-user-payload message-payload (producer/get-channel-retry-count topic-entity channel))]
+          user-payload (create-user-payload message-payload (get-channel-retry-count topic-entity channel))]
       (clog/with-logging-context {:consumer-group topic-entity-name :channel channel-name}
         (nr/with-tracing "job" metric-namespace
           (try