lib/sqsrun/controller.rb in sqsrun-0.4.0 vs lib/sqsrun/controller.rb in sqsrun-0.5.0

- old
+ new

@@ -15,12 +15,39 @@ @sqs = RightAws::SqsGen2.new(@key_id, @secret_key) @queue = @sqs.queue(@queue_name, true, @visibility_timeout) @queue.send_message(body) end + def create + @sqs = RightAws::SqsGen2.new(@key_id, @secret_key) + @queue = @sqs.queue(@queue_name, false) + if @queue + return nil + end + @queue = @sqs.queue(@queue_name, true) + end + + def delete(force=false) + @sqs = RightAws::SqsGen2.new(@key_id, @secret_key) + @queue = @sqs.queue(@queue_name, false) + unless @queue + return nil + end + @queue.delete(force) + end + def list @sqs = RightAws::SqsGen2.new(@key_id, @secret_key) - @sqs.queues.map {|q| q.name } + @sqs.queues + end + + def set_attribute(k, v) + @sqs = RightAws::SqsGen2.new(@key_id, @secret_key) + @queue = @sqs.queue(@queue_name, false) + unless @queue + return nil + end + @queue.set_attribute(k, v) end end end