enables jmx for rabbit-mq channel pool

gojek · Apr 11, 2022 · 3d36bc5 · 3d36bc5
1 parent 416cc20
commit 3d36bc5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/ziggurat/messaging/channel_pool.clj b/src/ziggurat/messaging/channel_pool.clj
@@ -31,7 +31,10 @@
       (.setMinIdle (:min-idle merged-config))
       (.setMaxIdle (:max-idle merged-config))
       (.setMaxTotal (+ (:min-idle merged-config) total-thread-count))
-      (.setTestOnBorrow true))))
+      (.setTestOnBorrow true)
+      (.setJmxEnabled true)
+      (.setJmxNameBase "rabbitmq-producer-channel-pool")
+      (.setJmxNamePrefix "ziggurat"))))
 
 (defn create-channel-pool [^Connection connection]
   (let [pool-config   (create-object-pool-config (get-in zc/ziggurat-config [:rabbit-mq-connection :channel-pool]))