module Evrone::Common::AMQP::Consumer::Ack

Public Instance Methods

ack!(multiple = false) click to toggle source
# File lib/evrone/common/amqp/consumer/ack.rb, line 6
def ack!(multiple = false)
  self.class.session.channel.ack delivery_info.delivery_tag, multiple
  debug "commit ##{delivery_info.delivery_tag.to_i}"
end
nack!(multiple = false, requeue = false) click to toggle source
# File lib/evrone/common/amqp/consumer/ack.rb, line 11
def nack!(multiple = false, requeue = false)
  self.class.session.channel.ack delivery_info.delivery_tag, multiple, requeue
  debug "reject ##{delivery_info.delivery_tag.to_i}"
end