Sha256: 8b005ae8415f558ba51125b6cd8dff4dcea6374f3be24b71f895eff8377e827e
Contents?: true
Size: 1.89 KB
Versions: 9
Compression:
Stored size: 1.89 KB
Contents
require 'spec_helper'
describe "Resque integration" do
let(:file) { File.expand_path('lib/appsignal/integrations/resque.rb') }
context "with resque" do
before do
module Resque
def self.before_first_fork
end
def self.after_fork
end
class Job
end
class TestError < StandardError
end
end
load file
start_agent
end
describe :around_perform_resque_plugin do
let(:transaction) { Appsignal::Transaction.new(1, {}) }
let(:job) { Resque::Job }
let(:invoked_job) { nil }
before do
transaction.stub(:complete! => true)
Appsignal::Transaction.stub(:current => transaction)
end
context "without exception" do
it "should create a new transaction" do
Appsignal::Transaction.should_receive(:create).and_return(transaction)
end
it "should instrument with correct params" do
ActiveSupport::Notifications.should_receive(:instrument).with(
'perform_job.resque',
:class => 'Resque::Job',
:method => 'perform'
)
end
it "should close the transaction" do
transaction.should_receive(:complete!)
end
after { job.around_perform_resque_plugin { invoked_job } }
end
context "with exception" do
it "should set the exception" do
transaction.should_receive(:add_exception)
end
after do
begin
job.around_perform_resque_plugin { raise(Resque::TestError.new('the roof')) }
rescue Resque::TestError
# Do nothing
end
end
end
end
end
context "without resque" do
before(:all) { Object.send(:remove_const, :Resque) }
specify { expect { ::Resque }.to raise_error(NameError) }
specify { expect { load file }.to_not raise_error }
end
end
Version data entries
9 entries across 9 versions & 1 rubygems