Class: CrawlKit::SQS

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

Class Method Summary collapse

Class Method Details

.clear_queue(name) ⇒ Object 



31
32
33
34
35
 
# File 'lib/crawl_kit/sqs.rb', line 31

def clear_queue(name)
  delete_queue(name)
  sleep(70)
  create_queue(name)
end

.connection ⇒ Object 



6
7
8
 
# File 'lib/crawl_kit/sqs.rb', line 6

def connection
  @connection ||= AWS::SQS.new
end

.consume_message(queue) ⇒ Object 



27
28
29
 
# File 'lib/crawl_kit/sqs.rb', line 27

def consume_message(queue)
  ActiveSupport::JSON.decode(queue.receive_message)
end

.create_queue(name) ⇒ Object Also known as: get_or_create_queue 



18
19
20
 
# File 'lib/crawl_kit/sqs.rb', line 18

def create_queue(name)
  connection.queues.create(name)
end

.delete_queue(name) ⇒ Object 



37
38
39
 
# File 'lib/crawl_kit/sqs.rb', line 37

def delete_queue(name)
  get_queue(name).try(:delete)
end

.enqueue_message(queue, message) ⇒ Object 



23
24
25
 
# File 'lib/crawl_kit/sqs.rb', line 23

def enqueue_message(queue, message)
  queue.send_message(ActiveSupport::JSON.encode(message))
end

.get_queue(name = "crawl_new") ⇒ Object 



10
11
12
 
# File 'lib/crawl_kit/sqs.rb', line 10

def get_queue(name="crawl_new")
  queues.detect{|queue|queue.name.eql?(name)}
end

.queues ⇒ Object 



14
15
16
 
# File 'lib/crawl_kit/sqs.rb', line 14

def queues
  connection.queues.to_a
end