Navigation Menu

Skip to content

Commit

Permalink
Use given "messages_per_second" option
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 10, 2015
1 parent 3bb61df commit 1bf2c7f
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions lib/drndump/dumper.rb
Expand Up @@ -39,9 +39,14 @@ def run(options={}, &block)

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
Expand Down

0 comments on commit 1bf2c7f

Please sign in to comment.