Sha256: 21e2b6b6361429c850a273bd1c5c3d942a1d2e9293d09a80e050be4d2219fffa
Contents?: true
Size: 435 Bytes
Versions: 21
Compression:
Stored size: 435 Bytes
Contents
module Shoryuken
module Middleware
module Server
class AutoDelete
def call(worker, queue, sqs_msg, body)
yield
return unless worker.class.auto_delete?
entries = [sqs_msg].flatten.map.with_index { |message, i| { id: i.to_s, receipt_handle: message.receipt_handle } }
Shoryuken::Client.queues(queue).delete_messages(entries: entries)
end
end
end
end
end
Version data entries
21 entries across 21 versions & 1 rubygems