Contents

module MultiWorker
  module Adapters
    class ThreadedInMemoryQueue
      def self.configure(base, opts={})
        base.class_eval do
          @queue = opts[:queue]

          def self.call(*args)
            perform(*args)
          end

          def self.perform(*args)
            self.new.perform(*args)
          end

          def self.perform_async(*args)
            ::ThreadedInMemoryQueue.enqueue(self, *args)
          end

          def perform_async(*args)
            self.class.perform_async(*args)
          end
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
multi_worker-0.2.0	lib/multi_worker/adapters/threaded_in_memory_queue.rb
multi_worker-0.1.0	lib/multi_worker/adapters/threaded_in_memory_queue.rb