lib/fluent/plugin/out_s3.rb in fluent-plugin-s3-0.5.1 vs lib/fluent/plugin/out_s3.rb in fluent-plugin-s3-0.5.2

@@ -48,10 +48,11 @@
       rescue => e
         $log.warn "#{@store_as} not found. Use 'text' instead"
         @compressor = TextCompressor.new
       end
       @compressor.configure(conf)
+      @compressor.buffer_type = @buffer_type
 
       # TODO: use Plugin.new_formatter instead of TextFormatter.create
       conf['format'] = @format
       @formatter = TextFormatter.create(conf)
 
@@ -146,9 +147,11 @@
       include Configurable
 
       def configure(conf)
         super
       end
+
+      attr_accessor :buffer_type
 
       def ext
       end
 
       def content_type