lib/vx/lib/consumer/ack.rb in vx-lib-consumer-0.2.2 vs lib/vx/lib/consumer/ack.rb in vx-lib-consumer-0.3.0

- old
+ new

@@ -2,39 +2,22 @@ module Lib module Consumer module Ack def ack(multiple = false) - instrumentation = { - consumer: self.class.params.consumer_name, - properties: properties, - multiple: multiple, - channel: _channel.id - } if _channel.open? _channel.ack delivery_info.delivery_tag, multiple - instrument("ack", instrumentation) true else - instrument("ack_failed", instrumentation) false end end def nack(multiple = false, requeue = false) - instrumentation = { - consumer: self.class.params.consumer_name, - properties: properties, - multiple: multiple, - requeue: requeue, - channel: channel.id - } if _channel.open? _channel.ack delivery_info.delivery_tag, multiple, requeue - instrument("nack", instrumentation) true else - instrument("nack_failed", instrumentation) false end end end