class Resugan::Worker::ParallelQueueDispatcher
Public Instance Methods
dispatch(namespace, events)
click to toggle source
# File lib/resugan/worker/parallel_queue_dispatcher.rb, line 12 def dispatch(namespace, events) @queues ||= {} @queues[namespace] ||= ParallelQueue.new(redis, 'resugan_queue-' + namespace) events.each do |k, v| @queues[namespace].enqueue('default', { event: k, args: v }.to_json) end end
redis()
click to toggle source
# File lib/resugan/worker/parallel_queue_dispatcher.rb, line 4 def redis @redis ||= Redis.new end
redis=(redis)
click to toggle source
# File lib/resugan/worker/parallel_queue_dispatcher.rb, line 8 def redis=(redis) @redis = redis end