lib/fluent/plugin/mqtt_output_mixin.rb in fluent-plugin-mqtt-io-0.0.2 vs lib/fluent/plugin/mqtt_output_mixin.rb in fluent-plugin-mqtt-io-0.0.3

@@ -10,11 +10,11 @@
       base.config_param :password, :string, :default => nil
       base.config_param :ssl, :bool, :default => nil
       base.config_param :ca_file, :string, :default => nil
       base.config_param :key_file, :string, :default => nil
       base.config_param :cert_file, :string, :default => nil
-      base.config_param :time_key, :string, :default => 'timestamp'
+      base.config_param :time_key, :string, :default => nil
       base.config_param :time_format, :string, :default => nil
       base.config_param :topic_rewrite_pattern, :string, :default => nil
       base.config_param :topic_rewrite_replacement, :string, :default => nil
     end
 
@@ -67,9 +67,17 @@
     def format_time(time)
       if @time_format.nil?
         Time.at(time).iso8601
       else
         Time.at(time).strftime(@time_format)
+      end
+    end
+
+    def timestamp_hash(time)
+      if @time_key.nil?
+        {}
+      else
+        {@time_key => format_time(time)}
       end
     end
 
     def rewrite_tag(tag)
       if @topic_rewrite_pattern.nil?