messaging.rb in avro_turf-1.12.0

- old
+ new

@@ -53,10 +53,11 @@
     # client_cert          - Name of file containing client certificate (optional).
     # client_key           - Name of file containing client private key to go with client_cert (optional).
     # client_key_pass      - Password to go with client_key (optional).
     # client_cert_data     - In-memory client certificate (optional).
     # client_key_data      - In-memory client private key to go with client_cert_data (optional).
+    # connect_timeout      - Timeout to use in the connection with the schema registry (optional).
     def initialize(
       registry: nil,
       registry_url: nil,
       schema_store: nil,
       schemas_path: nil,
@@ -69,11 +70,12 @@
       ssl_ca_file: nil,
       client_cert: nil,
       client_key: nil,
       client_key_pass: nil,
       client_cert_data: nil,
-      client_key_data: nil
+      client_key_data: nil,
+      connect_timeout: nil
     )
       @logger = logger || Logger.new($stderr)
       @namespace = namespace
       @schema_store = schema_store || SchemaStore.new(path: schemas_path || DEFAULT_SCHEMAS_PATH)
       @registry = registry || CachedConfluentSchemaRegistry.new(
@@ -87,10 +89,11 @@
           client_cert: client_cert,
           client_key: client_key,
           client_key_pass: client_key_pass,
           client_cert_data: client_cert_data,
           client_key_data: client_key_data,
-          path_prefix: registry_path_prefix
+          path_prefix: registry_path_prefix,
+          connect_timeout: connect_timeout
         )
       )
       @schemas_by_id = {}
     end
 