Sha256: 51b757feab9610232cc79c4f6cb790f5e2441c9b69d17c84e78d3ceb8693d9cb
Contents?: true
Size: 347 Bytes
Versions: 8
Compression:
Stored size: 347 Bytes
Contents
require 'qs/queue'
require 'qs/dispatch_job_handler'
module Qs
module DispatcherQueue
def self.new(options)
options[:queue_class].new do
name options[:queue_name]
job options[:job_name], options[:job_handler_class_name]
end
end
RunDispatchJob = Class.new{ include Qs::DispatchJobHandler }
end
end
Version data entries
8 entries across 8 versions & 1 rubygems