Class: Drano::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/drano/queue.rb

Instance Method Summary collapse

Constructor Details

#initialize(args = {}) ⇒ Queue

{{{



6
7
8
9
10
11
12
13
 
# File 'lib/drano/queue.rb', line 6

def initialize(args={}) # {{{
  @access_key = args[:access_key]
  @secret_key = args[:secret_key]
  @queue_name = args[:queue_name]

  sqs = AWS::SQS.new :access_key_id => @access_key, :secret_access_key => @secret_key
  @queue = sqs.queues.create(@queue_name)
end

Instance Method Details

#poll(&block) ⇒ Object

}}}



15
16
17
18
19
 
# File 'lib/drano/queue.rb', line 15

def poll(&block) # {{{
  @queue.poll do |message|
    block.call(message)
  end
end