Class: Sqs::Service

Inherits:
Object
  • Object
show all
Extended by:
Roxy::Moxie
Includes:
Parser
Defined in:
lib/sqs/service.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Roxy::Moxie

proxy

Methods included from Parser

#parse_create_queue_result, #parse_error, #parse_get_queue_attributes_result, #parse_list_queues_result, #parse_receive_message_result, #rexml_document

Constructor Details

#initialize(options) ⇒ Service

Parameters:

options

a hash of options described below

Options:

access_key_id

Amazon access key id, required

secret_access_key

Amazon secret access key, required

use_ssl

true if use ssl in connection, otherwise false

timeout

parameter for Net::HTTP module

debug

prints the raw requests to STDOUT



22
23
24
25
26
27
28
# File 'lib/sqs/service.rb', line 22

def initialize(options)
  @access_key_id = options[:access_key_id] or raise ArgumentError, "No access key id given"
  @secret_access_key = options[:secret_access_key] or raise ArgumentError, "No secret access key given"
  @use_ssl = options[:use_ssl]
  @timeout = options[:timeout]
  @debug = options[:debug]
end

Instance Attribute Details

#access_key_idObject (readonly)

Returns the value of attribute access_key_id.



6
7
8
# File 'lib/sqs/service.rb', line 6

def access_key_id
  @access_key_id
end

#secret_access_keyObject (readonly)

Returns the value of attribute secret_access_key.



6
7
8
# File 'lib/sqs/service.rb', line 6

def secret_access_key
  @secret_access_key
end

#use_sslObject (readonly)

Returns the value of attribute use_ssl.



6
7
8
# File 'lib/sqs/service.rb', line 6

def use_ssl
  @use_ssl
end

Instance Method Details

#==(other) ⇒ Object

Compares service to other, by access_key_id and secret_access_key



9
10
11
# File 'lib/sqs/service.rb', line 9

def ==(other)
  self.access_key_id == other.access_key_id and self.secret_access_key == other.secret_access_key
end

#inspectObject

:nodoc:



74
75
76
# File 'lib/sqs/service.rb', line 74

def inspect #:nodoc:
  "#<#{self.class}:#@access_key_id>"
end

#queues(reload = false) ⇒ Object

Returns all queues in the service and caches the result (see reload)



31
32
33
34
35
36
37
# File 'lib/sqs/service.rb', line 31

def queues(reload = false)
  if reload or @queues.nil?
    @queues = list_queues
  else
    @queues
  end
end