Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Adding -fn postfixes to consumer function keys

  • Loading branch information...
commit 8802c6240bd8cec956270bc9d8ff6c37718f9fa9 1 parent 0784939
@ifesdjeen ifesdjeen authored
Showing with 5 additions and 5 deletions.
  1. +5 −5 src/clojure/langohr/consumers.clj
View
10 src/clojure/langohr/consumers.clj
@@ -61,9 +61,9 @@
options' (apply dissoc (concat [options] keys))
consumer (create-default channel
:handle-delivery-fn f
- :handle-consume-ok (get cons-opts :handle-consume-ok)
- :handle-cancel-ok (get cons-opts :handle-cancel-ok)
- :handle-cancel (get cons-opts :handle-cancel)
- :handle-recover-ok (get cons-opts :handle-recover-ok)
- :handle-shutdown-signal (get cons-opts :handle-shutdown-signal))]
+ :handle-consume-ok-fn (get cons-opts :handle-consume-ok)
+ :handle-cancel-ok-fn (get cons-opts :handle-cancel-ok)
+ :handle-cancel-fn (get cons-opts :handle-cancel)
+ :handle-recover-ok-fn (get cons-opts :handle-recover-ok)
+ :handle-shutdown-signal-fn (get cons-opts :handle-shutdown-signal))]
(apply lhb/consume channel queue consumer (flatten (vec options')))))
Please sign in to comment.
Something went wrong with that request. Please try again.