From 3d36bc5acf2942610945179d861c090e6ff1d272 Mon Sep 17 00:00:00 2001 From: "shubhang.balkundi" Date: Mon, 11 Apr 2022 20:43:40 +0530 Subject: [PATCH] enables jmx for rabbit-mq channel pool --- src/ziggurat/messaging/channel_pool.clj | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/ziggurat/messaging/channel_pool.clj b/src/ziggurat/messaging/channel_pool.clj index d7dcc190..89aaacec 100644 --- 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]))