Module: Sqskiq::AWS

Included in:
Deleter, Fetcher
Defined in:
lib/sqskiq/aws.rb

Instance Method Summary collapse

Instance Method Details

#delete_sqs_messages(messages) ⇒ Object 



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

def delete_sqs_messages(messages)
  @queue.batch_delete(messages)
end

#fetch_sqs_messages ⇒ Object 



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

def fetch_sqs_messages
  @queue.receive_message(:limit => 10, :attributes => [:receive_count])
end

#init_queue(aws_access_key_id, aws_secret_access_key, queue_name) ⇒ Object 



6
7
8
9
 
# File 'lib/sqskiq/aws.rb', line 6

def init_queue(aws_access_key_id, aws_secret_access_key, queue_name)
  sqs = ::AWS::SQS.new(:access_key_id => aws_access_key_id, :secret_access_key => aws_secret_access_key)
  @queue = sqs.queues.named(queue_name.to_s)
end