From e8b4324952c6dbf32f53e6c092a4ef74edd46c17 Mon Sep 17 00:00:00 2001 From: Hiroshi Hatake Date: Mon, 1 May 2017 11:59:51 +0900 Subject: [PATCH 1/2] Make #start and #shutdown symmetric --- lib/fluent/plugin/out_bufferize.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/fluent/plugin/out_bufferize.rb b/lib/fluent/plugin/out_bufferize.rb index 87fd555..da5e2c6 100644 --- a/lib/fluent/plugin/out_bufferize.rb +++ b/lib/fluent/plugin/out_bufferize.rb @@ -104,8 +104,8 @@ def start end def shutdown - super @output.shutdown + super end def format(tag, time, record) From f3b241e7ac6615c6afbb4c193ff3e5af962076cd Mon Sep 17 00:00:00 2001 From: Hiroshi Hatake Date: Mon, 1 May 2017 12:39:04 +0900 Subject: [PATCH 2/2] Permit to @type style for specifying plugin type --- lib/fluent/plugin/out_bufferize.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/fluent/plugin/out_bufferize.rb b/lib/fluent/plugin/out_bufferize.rb index da5e2c6..2987cb8 100644 --- a/lib/fluent/plugin/out_bufferize.rb +++ b/lib/fluent/plugin/out_bufferize.rb @@ -89,9 +89,9 @@ def configure(conf) raise ConfigError, "Befferize: just one directive is required" end - type = configs.first['type'] + type = configs.first['type'] || configs.first['@type'] unless type - raise ConfigError, "Befferize: 'type' parameter is required in directive" + raise ConfigError, "Befferize: '@type' parameter is required in directive" end @output = Plugin.new_output(type)