lib/fluent/plugin/out_azureeventhubs_buffered.rb in sk-fluent-plugin-azureeventhubs-0.0.8 vs lib/fluent/plugin/out_azureeventhubs_buffered.rb in sk-fluent-plugin-azureeventhubs-0.0.11

@@ -1,8 +1,9 @@
-module Fluent::Plugin
+require 'thread'
+require 'fluent/output'
 
-  class AzureEventHubsOutputBuffered  < Output
+class AzureEventHubsOutputBuffered  < Fluent::BufferedOutput
     Fluent::Plugin.register_output('azureeventhubs_buffered', self)
 
     helpers :compat_parameters, :inject
 
     DEFAULT_BUFFER_TYPE = "memory"
@@ -56,7 +57,6 @@
     def write(chunk)
       chunk.msgpack_each { |tag, time, record|
         @sender.send_w_properties(record, @message_properties)
       }
     end
-  end
-end
+  end
\ No newline at end of file