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