Module: Vx::Common::AMQP::Consumer::Ack

Included in:
Vx::Common::AMQP::Consumer
Defined in:
lib/vx/common/amqp/consumer/ack.rb

Instance Method Summary collapse

Instance Method Details

#ack!(multiple = false) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
 
# 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) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
 
# 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