def create name, options = {}
if options[:default_visibility_timeout]
options[:visibility_timeout] =
options.delete(:default_visibility_timeout)
end
if policy = options[:policy]
options[:policy] = policy.to_json unless policy.is_a?(String)
end
client_opts = {}
client_opts[:queue_name] = name
unless options.empty?
client_opts[:attributes] = options.inject({}) do |attributes,(k,v)|
attributes.merge(Core::Inflection.class_name(k.to_s) => v.to_s)
end
end
response = client.create_queue(client_opts)
Queue.new(response.queue_url, :config => config)
end