Module: Evrone::Common::AMQP::Consumer::Ack

Included in:
Evrone::Common::AMQP::Consumer
Defined in:
lib/evrone/common/amqp/consumer/ack.rb

Instance Method Summary collapse

Instance Method Details

#ack!(multiple = false) ⇒ Object 



6
7
8
9
 
# 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) ⇒ Object 



11
12
13
14
 
# 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