Sha256: 7bb18390453c6b035320ccef78d4cd4006b648d88e60378abd15b3f46d48278f
Contents?: true
Size: 1.65 KB
Versions: 11
Compression:
Stored size: 1.65 KB
Contents
# -*- coding: utf-8 -*-
require 'spec_helper'
require 'stringio'
describe "uc80_raise_io_error" do
before(:all) do
@logger = Tengine.logger
end
after(:all) do
Tengine.logger = @logger
end
before do
Tengine::Core::Driver.delete_all
Tengine::Core::Session.delete_all
@dsl_path = File.expand_path('../../../../examples/uc80_raise_io_error.rb', File.dirname(__FILE__))
@config = Tengine::Core::Config::Core.new({
:tengined => {
:load_path => @dsl_path,
},
})
@bootstrap = Tengine::Core::Bootstrap.new(@config)
@kernel = Tengine::Core::Kernel.new(@config)
end
it "例外がraiseされると、その例外の内容がログに出力され、イベント処理エラーイベントをfireする" do
@bootstrap.load_dsl
@kernel.bind
mock_headers = mock(:headers)
mock_headers.should_receive(:ack)
raw_event = Tengine::Event.new(:event_type_name => "event80")
@buffer = StringIO.new
Tengine.logger = Logger.new(@buffer)
Tengine.logger.level = Logger::ERROR
@kernel.should_receive(:fire).with("event80.error.tengined",
:properties => {
:original_event => instance_of(String),
:error_class_name => "IOError",
:error_message => "by driver80",
:error_backtrace => instance_of(Array),
# :block_source_location => "#{@dsl_path}:6" # 6はブロックの行番号
})
Tengine::Core::Kernel.temp_exception_reporter(:except_test) do
expect{
@kernel.process_message(mock_headers, raw_event.to_json)
}.to_not raise_error
end
@buffer.rewind
@buffer.string.should =~ /\[IOError\] by driver80/
end
end
Version data entries
11 entries across 11 versions & 1 rubygems