Contents

module Eventboss
  # UnitOfWork handles calls a listener for each message and deletes on success
  class UnitOfWork
    include Logging
    include SafeThread

    attr_accessor :queue, :listener, :message

    def initialize(client, queue, listener, message)
      @client = client
      @queue = queue
      @listener = listener
      @message = message
      @logger = logger
    end

    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

    def change_message_visibility(postponed_by)
      @client.change_message_visibility(
        queue_url: @queue.url,
        receipt_handle: @message.receipt_handle,
        visibility_timeout: postponed_by
      )
    end

    def cleanup
      @client.delete_message(
        queue_url: @queue.url, receipt_handle: @message.receipt_handle
      )
      logger.debug(@message.message_id) { 'Deleting' }
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
eventboss-1.9.2	lib/eventboss/unit_of_work.rb
eventboss-1.9.1	lib/eventboss/unit_of_work.rb
eventboss-1.9.0	lib/eventboss/unit_of_work.rb
eventboss-1.8.1	lib/eventboss/unit_of_work.rb
eventboss-1.8.0	lib/eventboss/unit_of_work.rb
eventboss-1.7.0	lib/eventboss/unit_of_work.rb
eventboss-1.5.0	lib/eventboss/unit_of_work.rb
eventboss-1.4.1	lib/eventboss/unit_of_work.rb
eventboss-1.3.5	lib/eventboss/unit_of_work.rb
eventboss-1.3.4	lib/eventboss/unit_of_work.rb
eventboss-1.3.3	lib/eventboss/unit_of_work.rb
eventboss-1.3.2	lib/eventboss/unit_of_work.rb