bin/keen_send in keen-0.0.4 vs bin/keen_send in keen-0.0.5
- old
+ new
@@ -40,6 +40,8 @@
# confirm required options:
required.each do |key|
raise OptionParser::MissingArgument.new("you must send `#{key}` when running this command") if options[key].nil?
end
-Keen::Client.process_queue(options)
+storage_handler = Keen::Client.create_new_storage_handler(options[:storage_mode])
+worker = Keen::Async::Worker.new(storage_handler)
+puts worker.process_queue