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