Contents

module Vx
  module Lib
    module Consumer
      module Ack

        def ack(multiple = false)
          if _channel.open?
            _channel.ack delivery_info.delivery_tag, multiple
            true
          else
            false
          end
        end

        def nack(multiple = false, requeue = false)
          if _channel.open?
            _channel.ack delivery_info.delivery_tag, multiple, requeue
            true
          else
            false
          end
        end

      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
vx-lib-consumer-0.3.4	lib/vx/lib/consumer/ack.rb
vx-lib-consumer-0.3.3	lib/vx/lib/consumer/ack.rb
vx-lib-consumer-0.3.2	lib/vx/lib/consumer/ack.rb
vx-lib-consumer-0.3.1	lib/vx/lib/consumer/ack.rb
vx-lib-consumer-0.3.0	lib/vx/lib/consumer/ack.rb