Contents

module Shoryuken
  module Middleware
    module Server
      class AutoDelete

        def call(worker, queue, sqs_msg, body)
          yield

          # I'm still deciding, but `auto_delete` will be probably deprecated soon
          delete = worker.class.get_shoryuken_options['delete'] || worker.class.get_shoryuken_options['auto_delete']

          Shoryuken::Client.queues(queue).batch_delete(*Array(sqs_msg)) if delete
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
shoryuken-0.0.3	lib/shoryuken/middleware/server/auto_delete.rb