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