Contents

# frozen_string_literal: true

require "tainbox"
require "active_support/core_ext/class/attribute"

class Rabbit::EventHandler
  include Tainbox

  attribute :project_id
  attribute :data
  attribute :message_info

  class_attribute :queue
  class_attribute :ignore_queue_conversion, default: false
  class_attribute :additional_job_configs, default: {}

  class << self
    private

    def queue_as(queue = nil, &block)
      self.queue = queue || block
    end

    def job_config(**config_opts)
      additional_job_configs.merge!(config_opts)
    end

    def job_configs(**config_opts)
      self.additional_job_configs = config_opts
    end
  end

  def initialize(message)
    self.attributes   = message.data
    self.data         = message.data
    self.project_id   = message.project_id
    self.message_info = message.arguments
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rabbit_messaging-1.1.0	lib/rabbit/event_handler.rb