lib/fluent/plugin/out_azureeventhubs_buffered.rb in sk-fluent-plugin-azureeventhubs-0.0.15 vs lib/fluent/plugin/out_azureeventhubs_buffered.rb in sk-fluent-plugin-azureeventhubs-0.0.16

@@ -1,5 +1,10 @@
+require "fluent/plugin/output"
+require 'fluent/output'
+require 'fluent/output_chain'
+require 'fluent/plugin/buffer'
+
 module Fluent::Plugin
 
   class AzureEventHubsOutputBuffered < Fluent::BufferedOutput
     Fluent::Plugin.register_output('azureeventhubs_buffered', self)
 
@@ -21,9 +26,25 @@
     config_param :message_properties, :hash, :default => nil
 
     config_section :buffer do
       config_set_default :@type, DEFAULT_BUFFER_TYPE
       config_set_default :chunk_keys, ['tag']
+    end
+
+    def initialize
+      super
+    end
+
+    def start
+      super
+    end
+
+    def shutdown
+      super
+    end
+
+    def prefer_buffered_processing
+      true
     end
 
     def configure(conf)
       compat_parameters_convert(conf, :buffer, :inject)
       super
\ No newline at end of file