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 



29
30
31
32
33
 
# File 'lib/crawl_kit/sqs.rb', line 29

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

.connection ⇒ Object 



4
5
6
 
# File 'lib/crawl_kit/sqs.rb', line 4

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

.consume_message(queue) ⇒ Object 



25
26
27
 
# File 'lib/crawl_kit/sqs.rb', line 25

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

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



16
17
18
 
# File 'lib/crawl_kit/sqs.rb', line 16

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

.delete_queue(name) ⇒ Object 



35
36
37
 
# File 'lib/crawl_kit/sqs.rb', line 35

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

.enqueue_message(queue, message) ⇒ Object 



21
22
23
 
# File 'lib/crawl_kit/sqs.rb', line 21

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

.get_queue(name = "crawl_new") ⇒ Object 



8
9
10
 
# File 'lib/crawl_kit/sqs.rb', line 8

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

.queues ⇒ Object 



12
13
14
 
# File 'lib/crawl_kit/sqs.rb', line 12

def queues
  connection.queues.to_a
end