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