Contents

require File.expand_path('../test_helper', __FILE__)

class AsyncUser; end

describe "Backburner::AsyncProxy class" do
  before do
    Backburner.default_queues.clear
    clear_jobs!(Backburner.configuration.primary_queue)
  end

  describe "for method_missing enqueue" do
    should "enqueue job onto worker with no args" do
      @async = Backburner::AsyncProxy.new(AsyncUser, 10, :pri => 1000, :ttr => 100)
      @async.foo
      pop_one_job do |job, body|
        assert_equal "AsyncUser", body["class"]
        assert_equal [10, "foo"], body["args"]
        assert_equal 100, job.ttr
        assert_equal 1000, job.pri
        job.delete
      end
    end

    should "enqueue job onto worker with args" do
      @async = Backburner::AsyncProxy.new(AsyncUser, 10, :pri => 1000, :ttr => 100)
      @async.bar(1, 2, 3)
      pop_one_job do |job, body|
        assert_equal "AsyncUser", body["class"]
        assert_equal [10, "bar", 1, 2, 3], body["args"]
        assert_equal 100, job.ttr
        assert_equal 1000, job.pri
        job.delete
      end
    end
  end # method_missing
end # AsyncProxy

Version data entries

53 entries across 53 versions & 2 rubygems

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