Sha256: 7d58f1485429d228aa149feba8ce6128db84dab43ead41ad9d2e414b1e3ceb5e

Contents?: true

Size: 712 Bytes

Versions: 1

Compression:

Stored size: 712 Bytes

Contents

require 'celluloid'
require 'sucker_punch/exceptions'
require 'sucker_punch/queue'
require 'sucker_punch/worker'
require 'sucker_punch/version'

module SuckerPunch
  def self.config(&block)
    instance_eval &block
  end

  def self.queue(options = {})
    raise MissingQueueName unless options[:name]
    raise MissingWorkerName unless options[:worker]

    klass = options.fetch(:worker)
    registry_name = options.fetch(:name)
    workers = options.fetch(:workers, nil)

    q = Queue.new(registry_name)
    q.register(klass, workers)
  end

  def self.logger
    Celluloid.logger
  end

  def self.logger=(logger)
    Celluloid.logger = logger
  end
end

require 'sucker_punch/railtie' if defined?(::Rails)

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
sucker_punch-0.5.1 lib/sucker_punch.rb