Contents

require 'spec_helper'

describe Worker do
  before(:each) do
    @q = Backend::InProcess.new
    @w = Worker.new do |w|
      w.backend = @q
    end
  end

  it "starts" do
    @w.start
  end

  context "pluggable exception handler" do
    it "raises exception if nothing is provided" do
      @q.put Exceptional.new
      expect { @w.start }.to raise_exception(RuntimeError, "Exceptional")
    end

    it "defaults to Quebert.config.worker.exception_handler handler" do
      @q.put Exceptional.new
      Quebert.config.worker.exception_handler = Proc.new{|e, opts| expect(e).to be_a(StandardError) }
      expect { @w.start }.to_not raise_exception
    end

    it "intercepts exceptions" do
      @q.put Exceptional.new
      @w.exception_handler = Proc.new{|e, opts| expect(e).to be_a(StandardError) }
      expect { @w.start }.to_not raise_exception
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
quebert-3.3.0	spec/worker_spec.rb
quebert-3.2.1	spec/worker_spec.rb
quebert-3.2.0	spec/worker_spec.rb