From 67e2514ef6c07ff0ce3e176c50889d5b0d802493 Mon Sep 17 00:00:00 2001 From: Dylan Paris Date: Tue, 21 Jun 2016 12:39:01 -0700 Subject: [PATCH] [#174] Message queue: add `qname` to arg map passed to queue handler (@dparis) Pass the qname value from the handle1 context as part of the argument map passed to the queue handler function. --- src/taoensso/carmine/message_queue.clj | 5 +++-- test/taoensso/carmine/tests/message_queue.clj | 6 +++--- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/taoensso/carmine/message_queue.clj b/src/taoensso/carmine/message_queue.clj index 45ff84d0..f2af3cfb 100644 --- a/src/taoensso/carmine/message_queue.clj +++ b/src/taoensso/carmine/message_queue.clj @@ -203,7 +203,8 @@ "Error handling %s queue message:\n%s" qname poll-reply)) {:keys [status throwable backoff-ms]} - (let [result (try (handler {:mid mid :message mcontent :attempt attempt}) + (let [result (try (handler {:qname qname :mid mid + :message mcontent :attempt attempt}) (catch Throwable t {:status :error :throwable t}))] (when (map? result) result))] @@ -295,7 +296,7 @@ (defn worker "Returns a threaded worker to poll for and handle messages `enqueue`'d to named queue. Options: - :handler - (fn [{:keys [mid message attempt]}]) that throws an ex + :handler - (fn [{:keys [qname mid message attempt]}]) that throws an ex or returns {:status <#{:success :error :retry}> :throwable :backoff-ms