Class: Queuel::SQS::Queue

Inherits:
Base::Queue show all
Extended by:
Forwardable
Defined in:
lib/queuel/sqs/queue.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Base::Queue

#max_pool_tasks, #peek, #pop, #receive

Methods included from Introspect

#const_with_nesting, #module_names

Constructor Details

#initialize(client, queue_name, credentials = {}) ⇒ Queue

Returns a new instance of Queue.



10
11
12
13
14
 
# File 'lib/queuel/sqs/queue.rb', line 10

def initialize(client, queue_name, credentials={})
  self.client = client
  self.name = queue_name
  self.credentials = credentials
end

Instance Attribute Details

#credentials ⇒ Object

Returns the value of attribute credentials.



8
9
10
 
# File 'lib/queuel/sqs/queue.rb', line 8

def credentials
  @credentials
end

Instance Method Details

#approximate_number_of_messages ⇒ Object 



22
23
24
 
# File 'lib/queuel/sqs/queue.rb', line 22

def approximate_number_of_messages
  queue_connection.approximate_number_of_messages
end

#push(message, options = {}) ⇒ Object 



17
18
19
20
 
# File 'lib/queuel/sqs/queue.rb', line 17

def push(message, options = {})
  built_message = build_push_message message, options.merge(credentials)
  queue_connection.send_message built_message
end

#size ⇒ Object 



26
27
28
 
# File 'lib/queuel/sqs/queue.rb', line 26

def size
  approximate_number_of_messages
end