Parent

Methods

RightAws::Sqs

RightAws::Sqs -- RightScale's Amazon SQS interface

The RightAws::Sqs class provides a complete interface to Amazon's Simple Queue Service. For explanations of the semantics of each call, please refer to Amazon's documentation at developer.amazonwebservices.com/connect/kbcategory.jspa?categoryID=31

Error handling: all operations raise an RightAws::AwsError in case of problems. Note that transient errors are automatically retried.

sqs    = RightAws::Sqs.new(aws_access_key_id, aws_secret_access_key)
queue1 = sqs.queue('my_awesome_queue')
 ...
queue2 = RightAws::Sqs::Queue.create(sqs, 'my_cool_queue', true)
puts queue2.size
 ...
message1 = queue2.receive
message1.visibility = 0
puts message1
 ...
queue2.clear(true)
queue2.send_message('Ola-la!')
message2 = queue2.pop
 ...
grantee1 = RightAws::Sqs::Grantee.create(queue2,'one_cool_guy@email.address')
grantee1.grant('FULLCONTROL')
grantee1.drop
 ...
grantee2 = queue.grantees('another_cool_guy@email.address')
grantee2.revoke('SENDMESSAGE')

Params is a hash:

{:server       => 'queue.amazonaws.com' # Amazon service host: 'queue.amazonaws.com' (default)
 :port         => 443                   # Amazon service port: 80 or 443 (default)
 :multi_thread => true|false            # Multi-threaded (connection per each thread): true or false (default)
 :signature_version => '0'              # The signature version : '0' or '1'(default)
 :logger       => Logger Object}        # Logger instance: logs to STDOUT if omitted }

Attributes

interface[R]

Public Class Methods

new(aws_access_key_id=nil, aws_secret_access_key=nil, params={}) click to toggle source
# File lib/sqs/right_sqs.rb, line 69
def initialize(aws_access_key_id=nil, aws_secret_access_key=nil, params={})
  @interface = SqsInterface.new(aws_access_key_id, aws_secret_access_key, params)
end

Public Instance Methods

queue(queue_name, create=true, visibility=nil) click to toggle source

Returns Queue instance by queue name. If the queue does not exist at Amazon SQS and create is true, the method creates it.

RightAws::Sqs.queue('my_awesome_queue') #=> #<RightAws::Sqs::Queue:0xb7b626e4 ... >
# File lib/sqs/right_sqs.rb, line 89
def queue(queue_name, create=true, visibility=nil)
  url = @interface.queue_url_by_name(queue_name)
  url = (create ? @interface.create_queue(queue_name, visibility) : nil) unless url
  url ? Queue.new(self, url) : nil
end
queues(prefix=nil) click to toggle source

Retrieves a list of queues. Returns an array of Queue instances.

RightAws::Sqs.queues #=> array of queues
# File lib/sqs/right_sqs.rb, line 78
def queues(prefix=nil)
  @interface.list_queues(prefix).map do |url|
    Queue.new(self, url)
  end
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.