Sha256: 90bca6fce962ec79b793281551b55485c6542e59b6b96fe683f2abad8c3cf336
Contents?: true
Size: 509 Bytes
Versions: 14
Compression:
Stored size: 509 Bytes
Contents
module FakeSQS
module Actions
class SendMessage
def initialize(options = {})
@server = options.fetch(:server)
@queues = options.fetch(:queues)
@responder = options.fetch(:responder)
end
def call(name, params)
queue = @queues.get(name)
message = queue.send_message(params)
@responder.call :SendMessage do |xml|
xml.MD5OfMessageBody message.md5
xml.MessageId message.id
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems