lib/fluent/plugin/out_elasticsearch_dynamic.rb in fluent-plugin-elasticsearch-1.7.0 vs lib/fluent/plugin/out_elasticsearch_dynamic.rb in fluent-plugin-elasticsearch-1.8.0

@@ -13,11 +13,11 @@
   config_param :utc_index, :string, :default => "true"
   config_param :time_key_exclude_timestamp, :bool, :default => false
   config_param :reload_connections, :string, :default => "true"
   config_param :reload_on_failure, :string, :default => "false"
   config_param :resurrect_after, :string, :default => "60"
-  config_param :ssl_verify, :string, :dfeault => "true"
+  config_param :ssl_verify, :string, :default => "true"
 
   def configure(conf)
     super
 
     # evaluate all configurations here
@@ -176,15 +176,15 @@
 
       append_record_to_messages(dynamic_conf["write_operation"], meta, record, bulk_message[host])
     end
 
     bulk_message.each do | hKey, array |
-      send(array, hKey) unless array.empty?
+      send_bulk(array, hKey) unless array.empty?
       array.clear
     end
   end
 
-  def send(data, host)
+  def send_bulk(data, host)
     retries = 0
     begin
       client(host).bulk body: data
     rescue *client(host).transport.host_unreachable_exceptions => e
       if retries < 2