class Eventboss::Fetcher
Constants
- FETCH_LIMIT
Attributes
client[R]
Public Class Methods
new(configuration)
click to toggle source
# File lib/eventboss/fetcher.rb, line 7 def initialize(configuration) @client = configuration.sqs_client end
Public Instance Methods
delete(queue, message)
click to toggle source
# File lib/eventboss/fetcher.rb, line 15 def delete(queue, message) @client.delete_message(queue_url: queue.url, receipt_handle: message.receipt_handle) end
fetch(queue, limit)
click to toggle source
# File lib/eventboss/fetcher.rb, line 11 def fetch(queue, limit) @client.receive_message(queue_url: queue.url, max_number_of_messages: max_no_of_messages(limit)).messages end
Private Instance Methods
max_no_of_messages(limit)
click to toggle source
# File lib/eventboss/fetcher.rb, line 21 def max_no_of_messages(limit) [limit, FETCH_LIMIT].min end