Class: Sqskiq::Fetcher

Inherits:
Object
  • Object
show all
Includes:
Celluloid, AWS
Defined in:
lib/sqskiq/fetch.rb

Instance Method Summary collapse

Methods included from AWS

#delete_sqs_messages, #fetch_sqs_messages, #init_queue

Constructor Details

#initialize(aws_access_key_id, aws_secret_access_key, queue_name) ⇒ Fetcher

Returns a new instance of Fetcher.



10
11
12
13
 
# File 'lib/sqskiq/fetch.rb', line 10

def initialize(aws_access_key_id, aws_secret_access_key, queue_name)
  init_queue(aws_access_key_id, aws_secret_access_key, queue_name)
  @manager = Celluloid::Actor[:manager]
end

Instance Method Details

#fetch ⇒ Object 



15
16
17
18
 
# File 'lib/sqskiq/fetch.rb', line 15

def fetch
  messages = fetch_sqs_messages
  @manager.async.fetch_done(messages)
end