Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP

Loading…

Fix basic/reject #11

Merged
merged 1 commit into from

2 participants

@natedev

The reject method was calling .basicAck instead of .basicReject

@natedev natedev Fix basic/regect
The reject method was calling .basicAck instead of .basicReject
ac01893
@michaelklishin michaelklishin merged commit 95a59d8 into michaelklishin:master
@michaelklishin

Released beta10 with this change in. Thank you very much!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Commits on Oct 25, 2012
  1. @natedev

    Fix basic/regect

    natedev authored
    The reject method was calling .basicAck instead of .basicReject
This page is out of date. Refresh to see the latest.
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/clojure/langohr/basic.clj
View
4 src/clojure/langohr/basic.clj
@@ -166,9 +166,9 @@
(defn reject
"Rejects (and, optionally, requeues) a messages using basic.reject AMQP method"
([^Channel channel ^long delivery-tag]
- (.basicAck channel delivery-tag false))
+ (.basicReject channel delivery-tag false))
([^Channel channel ^long delivery-tag ^Boolean requeue]
- (.basicAck channel delivery-tag requeue)))
+ (.basicReject channel delivery-tag requeue)))
(defn nack
Something went wrong with that request. Please try again.