Sha256: eb59448ff9e81b8fb30f85b5cab9c745d4fc512845d27d509d4c7b7dee6a8078
Contents?: true
Size: 1000 Bytes
Versions: 1
Compression:
Stored size: 1000 Bytes
Contents
exit if jruby? ENV["DATABASE_URL"] ||= "postgres:///queue_classic_test" require 'queue_classic' module QC class Queue def enqueue(method, *args) klass = eval(method.split(".").first) message = method.split(".").last klass.send(message, *args) end end end require 'test_workers' describe TestWorker do it_behaves_like "a worker" end describe MultiWorker do context "when Queue Classic is loaded" do it "defaults to the :queue_classic adapter" do expect(MultiWorker.default_adapter).to eq(:queue_classic) end end context "when using the :queue_classic adapter" do it "performs the work using Queue Classic" do expect(TestWorker).to receive(:perform).exactly(3).times.with("foo") TestWorker.perform_async("foo") MultiWorker.enqueue(TestWorker, "foo") TestWorker.perform("foo") end it "exposes the Queue Classic rake task" do expect(MultiWorker.adapter.rake_task.name).to eq("qc:work") end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
multi_worker-0.2.0 | spec/adapters/queue_classic_spec.rb |