def create_queue(name, attributes = {})
      response = action("CreateQueue", {"QueueName" => Queue.sanitize_name("#{queue_prefix}#{name}")}.merge(attributes))

      if response.success?
        Queue.new(self, response.doc.xpath("//QueueUrl").text)
      else
        raise "Could not create queue #{name}"
      end

    rescue AwsActionError => error
      if error.code == "AWS.SimpleQueueService.QueueDeletedRecently"
        raise QueueDeletedRecentlyError, error.message
      else
        raise error
      end
    end
def create_queue(name, attributes = {})
      response = action("CreateQueue", {"QueueName" => Queue.sanitize_name("#{queue_prefix}#{name}")}.merge(attributes))

      if response.success?
        Queue.new(self, response.doc.xpath("//QueueUrl").text)
      else
        raise "Could not create queue #{name}"
      end

    rescue AwsActionError => error
      if error.code == "AWS.SimpleQueueService.QueueDeletedRecently"
        raise QueueDeletedRecentlyError, error.message
      else
        raise error
      end
    end
Creates a new SQS queue and returns a Queue object.

 @param [String] name
 @param [Hash] attributes
 @return [Queue]
 @raise [AwsActionError]