YUKI Hiroshi
null+****@clear*****
Wed Apr 15 20:28:42 JST 2015
YUKI Hiroshi 2015-04-15 20:28:42 +0900 (Wed, 15 Apr 2015) New Revision: 29026233adc9e8a8a98130990e4b22e3fd8ad5db https://github.com/droonga/droonga-engine/commit/29026233adc9e8a8a98130990e4b22e3fd8ad5db Message: Separate options for DumpClient#run from parameters for its constructor Modified files: lib/droonga/plugins/system/absorb_data.rb Modified: lib/droonga/plugins/system/absorb_data.rb (+7 -6) =================================================================== --- lib/droonga/plugins/system/absorb_data.rb 2015-04-15 20:18:26 +0900 (3db8f43) +++ lib/droonga/plugins/system/absorb_data.rb 2015-04-15 20:28:42 +0900 (b388b1e) @@ -72,7 +72,7 @@ module Droonga logger.info("#{count} records to be absorbed") end logger.info("starting to absorb the source dataset") - @dumper_error_message = dumper.run do |message| + @dumper_error_message = dumper.run(dump_options) do |message| begin message["dataset"] = current_dataset @messenger.forward(message, @@ -135,12 +135,13 @@ module Droonga :receiver_host => myself.host, :receiver_port => 0, + } + end - :client_options => { - :backend => :coolio, - :loop => @loop, - }, - + def dump_options + { + :backend => :coolio, + :loop => @loop, :messages_per_second => messages_per_second, } end -------------- next part -------------- HTML����������������������������...다운로드
