Contents

module SuckerPunch
  class Queue
    attr_reader :name

    def initialize(name)
      @name = name
    end

    def self.[](name)
      Celluloid::Actor[name]
    end

    def register(klass, size)
      Celluloid::Actor[name] = if size
                                  klass.send(:pool, size: size)
                                else
                                  klass.send(:pool)
                                end
    end

    def method_missing(method_name, *args, &block)
      Celluloid::Actor[name].send(method_name, *args, &block)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sucker_punch-0.3.1	lib/sucker_punch/queue.rb
sucker_punch-0.3	lib/sucker_punch/queue.rb