Sha256: 48a46688fc73cc941ab0680cb937b3db1679e75c80bb2bd8ed287f28f9347b34
Contents?: true
Size: 1.08 KB
Versions: 14
Compression:
Stored size: 1.08 KB
Contents
module FakeSQS
module Actions
class SendMessageBatch
def initialize(options = {})
@server = options.fetch(:server)
@queues = options.fetch(:queues)
@responder = options.fetch(:responder)
end
def call(name, params)
queue = @queues.get(name)
messages = params.select { |k,v| k =~ /SendMessageBatchRequestEntry\.\d+\.MessageBody/ }
results = {}
messages.each do |key, value|
id = key.split('.')[1]
msg_id = params.fetch("SendMessageBatchRequestEntry.#{id}.Id")
delay = params["SendMessageBatchRequestEntry.#{id}.DelaySeconds"]
message = queue.send_message("MessageBody" => value, "DelaySeconds" => delay)
results[msg_id] = message
end
@responder.call :SendMessageBatch do |xml|
results.each do |msg_id, message|
xml.SendMessageBatchResultEntry do
xml.Id msg_id
xml.MessageId message.id
xml.MD5OfMessageBody message.md5
end
end
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems