module Vx::Common::AMQP::Consumer::Ack
Public Instance Methods
ack!(multiple = false)
click to toggle source
# File lib/vx/common/amqp/consumer/ack.rb, line 6 def ack!(multiple = false) instrumentation = { consumer_id: self.class.consumer_id, consumer: self.class.consumer_name, properties: properties, multiple: multiple, } self.class.session.channel.ack delivery_info.delivery_tag, multiple instrument("ack.consumer.amqp", instrumentation) end
nack!(multiple = false, requeue = false)
click to toggle source
# File lib/vx/common/amqp/consumer/ack.rb, line 17 def nack!(multiple = false, requeue = false) instrumentation = { consumer_id: self.class.consumer_id, consumer: self.class.consumer_name, properties: properties, multiple: multiple, requeue: requeue, } self.class.session.channel.ack delivery_info.delivery_tag, multiple, requeue instrument("nack.consumer.amqp", instrumentation) end