Contents

module Sneakers
  module Handlers
    class Oneshot
      def initialize(channel, queue, opts)
        @channel = channel
        @opts = opts
      end

      def acknowledge(hdr, props, msg)
        @channel.acknowledge(hdr.delivery_tag, false)
      end

      def reject(hdr, props, msg, requeue=false)
        @channel.reject(hdr.delivery_tag, requeue)
      end

      def error(hdr, props, msg, err)
        reject(hdr, props, msg)
      end

      def noop(hdr, props, msg)

      end
    end
  end
end

Version data entries

8 entries across 8 versions & 2 rubygems

Version	Path
kicks-3.2.0	lib/sneakers/handlers/oneshot.rb
kicks-3.1.1	lib/sneakers/handlers/oneshot.rb
kicks-3.1.0	lib/sneakers/handlers/oneshot.rb
kicks-3.0.0	lib/sneakers/handlers/oneshot.rb
kicks-3.0.0.pre	lib/sneakers/handlers/oneshot.rb
sneakers-2.12.0	lib/sneakers/handlers/oneshot.rb
sneakers-2.12.0.rc1	lib/sneakers/handlers/oneshot.rb
sneakers-2.11.0	lib/sneakers/handlers/oneshot.rb