Sha256: 05b41f63b3ab4d29347e8a692247999a8a3b7b7f9818d5ae2d641a97f63da1f2
Contents?: true
Size: 456 Bytes
Versions: 14
Compression:
Stored size: 456 Bytes
Contents
module FakeSQS
module Actions
class DeleteMessage
def initialize(options = {})
@server = options.fetch(:server)
@queues = options.fetch(:queues)
@responder = options.fetch(:responder)
end
def call(name, params)
queue = @queues.get(name)
receipt = params.fetch("ReceiptHandle")
queue.delete_message(receipt)
@responder.call :DeleteMessage
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems