Contents

module Resugan
  module Worker
    class ParallelQueueDispatcher
      def redis
        @redis ||= Redis.new
      end

      def redis=(redis)
        @redis = redis
      end

      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
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
resugan-worker-0.1.2	lib/resugan/worker/parallel_queue_dispatcher.rb
resugan-worker-0.1.1	lib/resugan/worker/parallel_queue_dispatcher.rb
resugan-worker-0.1.0	lib/resugan/worker/parallel_queue_dispatcher.rb