class Queuel::SQS::Queue
Attributes
credentials[RW]
Public Class Methods
new(client, queue_name, credentials={})
click to toggle source
# 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
Public Instance Methods
approximate_number_of_messages()
click to toggle source
# File lib/queuel/sqs/queue.rb, line 22 def approximate_number_of_messages queue_connection.approximate_number_of_messages end
push(message, options = {})
click to toggle source
# 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()
click to toggle source
# File lib/queuel/sqs/queue.rb, line 26 def size approximate_number_of_messages end
Private Instance Methods
build_new_message(bare_message, options = {})
click to toggle source
# File lib/queuel/sqs/queue.rb, line 32 def build_new_message(bare_message, options = {}) message_klass.new(bare_message, credentials) end
pop_bare_message(options = {})
click to toggle source
# File lib/queuel/sqs/queue.rb, line 36 def pop_bare_message(options = {}) queue_connection.receive_message options end
queue_connection()
click to toggle source
# File lib/queuel/sqs/queue.rb, line 40 def queue_connection @queue_connection ||= client.queues.named(name) end