Method: SQS.create_queue

Defined in:
lib/sqs.rb

.create_queue(params = {}) ⇒ Object 



92
93
94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/sqs.rb', line 92

def self.create_queue( params={} )
  params = params.is_a?( Hash ) ? params : { :name => params }
  params[:Action] = 'CreateQueue'
  return false if params[:name].to_s.empty?
  params[:QueueName] = params[:name]
  params.delete( :name )

  doc = self.call_web_service( params )
  queue_url = doc.queue_url
  SQS::Queue.new( :url => queue_url )

rescue Exception => e
  raise e
end