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