class Eventboss::UnitOfWork

UnitOfWork handles calls a listener for each message and deletes on success

Attributes

listener[RW]
message[RW]
queue[RW]

Public Class Methods

new(client, queue, listener, message) click to toggle source
# File lib/eventboss/unit_of_work.rb, line 9
def initialize(client, queue, listener, message)
  @client = client
  @queue = queue
  @listener = listener
  @message = message
  @logger = logger
end

Public Instance Methods

change_message_visibility(postponed_by) click to toggle source
# File lib/eventboss/unit_of_work.rb, line 30
def change_message_visibility(postponed_by)
  @client.change_message_visibility(
    queue_url: @queue.url,
    receipt_handle: @message.receipt_handle,
    visibility_timeout: postponed_by
  )
end
cleanup() click to toggle source
# File lib/eventboss/unit_of_work.rb, line 38
def cleanup
  @client.delete_message(
    queue_url: @queue.url, receipt_handle: @message.receipt_handle
  )
  logger.debug(@message.message_id) { 'Deleting' }
end
run() click to toggle source
# File lib/eventboss/unit_of_work.rb, line 17
def run
  logger.debug(@message.message_id) { 'Started' }
  processor = @listener.new
  processor.receive(JSON.parse(@message.body))
  logger.debug(@message.message_id) { 'Finished' }
rescue StandardError => exception
  handle_exception(exception, processor: processor, message_id: @message.message_id)
else
  cleanup unless processor.postponed_by
ensure
  change_message_visibility(processor.postponed_by) if processor.postponed_by
end