lib/fluent/plugin/out_azureeventhubs_buffered.rb in fluent-plugin-azureeventhubs-0.0.3 vs lib/fluent/plugin/out_azureeventhubs_buffered.rb in fluent-plugin-azureeventhubs-0.0.4

@@ -10,18 +10,20 @@
     config_param :tag_time_name, :string, :default => 'time'
     config_param :expiry_interval, :integer, :default => 3600 # 60min
     config_param :type, :string, :default => 'https' # https / amqps (Not Implemented) 
     config_param :proxy_addr, :string, :default => ''
     config_param :proxy_port, :integer,:default => 3128
+    config_param :open_timeout, :integer,:default => 60
+    config_param :read_timeout, :integer,:default => 60
 
     def configure(conf)
       super
       case @type
       when 'amqps'
         raise NotImplementedError
       else
         require_relative 'azureeventhubs/http'
-        @sender = AzureEventHubsHttpSender.new(@connection_string, @hub_name, @expiry_interval,@proxy_addr,@proxy_port)
+        @sender = AzureEventHubsHttpSender.new(@connection_string, @hub_name, @expiry_interval,@proxy_addr,@proxy_port,@open_timeout,@read_timeout)
       end
     end
 
     def format(tag, time, record)
       [tag, time, record].to_msgpack