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 timeout(hdr, props, msg)
        reject(hdr, props, msg)
      end

      def noop(hdr, props, msg)

      end
    end
  end
end

Version data entries

21 entries across 21 versions & 2 rubygems

Version	Path
sneakers-2.7.0	lib/sneakers/handlers/oneshot.rb
sneakers-2.6.0	lib/sneakers/handlers/oneshot.rb
sneakers-2.5.0	lib/sneakers/handlers/oneshot.rb
sneakers-2.4.0	lib/sneakers/handlers/oneshot.rb
sneakers-2.3.5	lib/sneakers/handlers/oneshot.rb
sneakers-2.3.4	lib/sneakers/handlers/oneshot.rb
sneakers-2.3.2	lib/sneakers/handlers/oneshot.rb
sneakers-2.3.1	lib/sneakers/handlers/oneshot.rb
sneakers-2.3.0	lib/sneakers/handlers/oneshot.rb
sneakers-2.2.1	lib/sneakers/handlers/oneshot.rb
sneakers-2.2.0	lib/sneakers/handlers/oneshot.rb
sneakers-2.1.0	lib/sneakers/handlers/oneshot.rb
sneakers-1.1.2	lib/sneakers/handlers/oneshot.rb
sneakers-1.1.1	lib/sneakers/handlers/oneshot.rb
sneakers-1.1.0	lib/sneakers/handlers/oneshot.rb
sneakers_custom_bunny-1.0.4	lib/sneakers/handlers/oneshot.rb
sneakers-1.0.4	lib/sneakers/handlers/oneshot.rb
sneakers-1.0.3	lib/sneakers/handlers/oneshot.rb
sneakers-1.0.2	lib/sneakers/handlers/oneshot.rb
sneakers-1.0.1	lib/sneakers/handlers/oneshot.rb