lib/fluent/plugin/out_map.rb in fluent-plugin-map-0.2.1 vs lib/fluent/plugin/out_map.rb in fluent-plugin-map-0.3.0
- old
+ new
@@ -42,9 +42,15 @@
configure_format()
@map = create_map(conf)
@map_support = Fluent::Plugin::MapSupport.new(@map, self)
end
+ def stop
+ @map_support.stop
+
+ super
+ end
+
def determine_format()
if @format
@format
elsif @map
"map"