Contents

# frozen_string_literal: true

module QueueBus
  class Worker
    def self.perform(json)
      klass = nil
      attributes = ::QueueBus::Util.decode(json)
      begin
        class_name = attributes['bus_class_proxy']
        klass = ::QueueBus::Util.constantize(class_name)
      rescue NameError
        # not there anymore
        return
      end

      QueueBus.worker_middleware_stack.run(attributes) do
        klass.perform(attributes)
      end
    end

    # all our workers include this one
    def perform(json)
      # instance method level support for sidekiq
      self.class.perform(json)
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
queue-bus-0.13.3	lib/queue_bus/worker.rb
queue-bus-0.13.2	lib/queue_bus/worker.rb
queue-bus-0.13.1	lib/queue_bus/worker.rb
queue-bus-0.13.0	lib/queue_bus/worker.rb
queue-bus-0.12.0	lib/queue_bus/worker.rb
queue-bus-0.11.0	lib/queue_bus/worker.rb
queue-bus-0.10.0	lib/queue_bus/worker.rb
queue-bus-0.9.1	lib/queue_bus/worker.rb