Sha256: 00ab2e91e04a365a4cc1658f08a194d08b3e03dc02e62fc8d27beacaf7f6e18a
Contents?: true
Size: 479 Bytes
Versions: 15
Compression:
Stored size: 479 Bytes
Contents
module SuckerPunch
module Job
def self.included(base)
base.send(:include, ::Celluloid)
base.extend(ClassMethods)
base.class_eval do
def self.new
define_celluloid_pool(self, @workers)
end
end
end
module ClassMethods
def workers(num)
@workers = num
end
def define_celluloid_pool(klass, num_workers)
SuckerPunch::Queue.new(klass).register(num_workers)
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems