lib/msgr/connection.rb in msgr-0.11.0.rc1 vs lib/msgr/connection.rb in msgr-0.11.0.rc2

- old
+ new

@@ -101,9 +101,14 @@ def ack(delivery_tag) channel.ack delivery_tag log(:debug) { "Acked message: #{delivery_tag}" } end + def nack(delivery_tag) + channel.nack delivery_tag, false, true + log(:debug) { "Nacked message: #{delivery_tag}" } + end + def reject(delivery_tag, requeue = true) channel.reject delivery_tag, requeue log(:debug) { "Rejected message: #{delivery_tag}" } end