Class: SqsQueuer::Queue

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(queue_url) ⇒ Queue

Returns a new instance of Queue.



9
10
11
12
13
14
15
 
# File 'lib/sqs_queuer.rb', line 9

def initialize(queue_url)
  @client = Aws::SQS::Client.new(
    access_key_id: ENV['AWS_KEY_ID'],
    secret_access_key: ENV['AWS_SECRET_ACCESS_KEY']
  )
  @queue_url = queue_url
end

Instance Attribute Details

#client ⇒ Object (readonly)

Returns the value of attribute client.



7
8
9
 
# File 'lib/sqs_queuer.rb', line 7

def client
  @client
end

#queue_url ⇒ Object (readonly)

Returns the value of attribute queue_url.



7
8
9
 
# File 'lib/sqs_queuer.rb', line 7

def queue_url
  @queue_url
end

Instance Method Details

#add_to_queue(body) ⇒ Object 



17
18
19
20
21
22
23
24
 
# File 'lib/sqs_queuer.rb', line 17

def add_to_queue(body)
  body = YAML::dump(body)

  client.send_message({
    queue_url: queue_url,
    message_body: body
  })
end

#pull_from_queue ⇒ Object 



26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/sqs_queuer.rb', line 26

def pull_from_queue
  resp = client.receive_message({
    queue_url: queue_url,
    max_number_of_messages: 1
  })

  if resp.messages[0]
    message = resp.messages[0]
    client.delete_message(queue_url: queue_url, receipt_handle: message.receipt_handle)
    YAML::load(message.body)
  end
end