lib/fluent/plugin/mqtt_output_mixin.rb in fluent-plugin-mqtt-io-0.0.1 vs lib/fluent/plugin/mqtt_output_mixin.rb in fluent-plugin-mqtt-io-0.0.2
- old
+ new
@@ -66,11 +66,10 @@
def format_time(time)
if @time_format.nil?
Time.at(time).iso8601
else
- time_parser = TimeParser.new(@time_format)
- time_parser.parse(time)
+ Time.at(time).strftime(@time_format)
end
end
def rewrite_tag(tag)
if @topic_rewrite_pattern.nil?