YUKI Hiroshi
null+****@clear*****
Fri Apr 10 13:34:26 JST 2015
YUKI Hiroshi 2015-04-10 13:34:26 +0900 (Fri, 10 Apr 2015) New Revision: 1bf2c7f8746348c3577b936d5958518c28c81929 https://github.com/droonga/drndump/commit/1bf2c7f8746348c3577b936d5958518c28c81929 Message: Use given "messages_per_second" option Modified files: lib/drndump/dumper.rb Modified: lib/drndump/dumper.rb (+5 -0) =================================================================== --- lib/drndump/dumper.rb 2015-04-10 12:33:31 +0900 (8a00638) +++ lib/drndump/dumper.rb 2015-04-10 13:34:26 +0900 (a6b8894) @@ -39,9 +39,14 @@ module Drndump n_dumpers = 0 + dump_params = {} + if options[:messages_per_second] + dump_params["messagesPerSecond"] = options[:messages_per_second] + end dump_message = { "type" => "dump", "dataset" => @dataset, + "body" => dump_params, } client.subscribe(dump_message) do |message| case message -------------- next part -------------- HTML����������������������������...Download