Sha256: 7ee27a90ffe07ebd093a42744ddfe1451e5c9bbd7ca42d70ac37c26a6d9a4aa8

Contents?: true

Size: 857 Bytes

Versions: 76

Compression:

Stored size: 857 Bytes

Contents

$:.unshift "lib"
require 'backburner'

class User
  include Backburner::Performable
  attr_accessor :id, :name

  def self.first
    User.find(3, "John")
  end

  def self.find(id, name="Fetched")
    User.new(id, name)
  end

  def initialize(id, name)
    @id, @name = id, name
  end

  def hello(x, y)
    puts "User(id=#{id}) #hello args: [#{x}, #{y}] (Instance method)"
  end

  def self.foo(x, y)
    puts "User #foo args [#{x}, #{y}] (Class method)"
  end
end

# Configure Backburner
Backburner.configure do |config|
  config.beanstalk_url = "beanstalk://127.0.0.1"
  config.tube_namespace = "demo.production"
  config.on_error = lambda { |e| puts "HEY!!! #{e.class}" }
end

# Enqueue tasks
@user = User.first
@user.async(:pri => 1000).hello("foo", "bar")
User.async.foo("bar", "baz")

# Run work
# Backburner.default_queues << "user"
Backburner.work

Version data entries

76 entries across 76 versions & 2 rubygems

Version Path
backburner-allq-1.0.50 examples/simple.rb
backburner-allq-1.0.49 examples/simple.rb
backburner-allq-1.0.48 examples/simple.rb
backburner-1.6.1 examples/simple.rb
backburner-allq-1.0.47 examples/simple.rb
backburner-allq-1.0.46 examples/simple.rb
backburner-allq-1.0.45 examples/simple.rb
backburner-allq-1.0.44 examples/simple.rb
backburner-allq-1.0.40 examples/simple.rb
backburner-allq-1.0.39 examples/simple.rb
backburner-allq-1.0.38 examples/simple.rb
backburner-allq-1.0.37 examples/simple.rb
backburner-allq-1.0.36 examples/simple.rb
backburner-1.6.0 examples/simple.rb
backburner-allq-1.0.35 examples/simple.rb
backburner-allq-1.0.34 examples/simple.rb
backburner-allq-1.0.33 examples/simple.rb
backburner-allq-1.0.32 examples/simple.rb
backburner-allq-1.0.31 examples/simple.rb
backburner-allq-1.0.29 examples/simple.rb