messaging.rb in avro_turf-1.3.0

- old
+ new

@@ -32,10 +32,12 @@
     # schema_store      - A schema store object that responds to #find(schema_name, namespace).
     # schemas_path      - The String file system path where local schemas are stored.
     # namespace         - The String default schema namespace.
     # logger            - The Logger that should be used to log information (optional).
     # proxy             - Forward the request via  proxy (optional).
+    # user              - User for basic auth (optional).
+    # password          - Password for basic auth (optional).
     # 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).
@@ -45,10 +47,12 @@
       schema_store: nil,
       schemas_path: nil,
       namespace: nil,
       logger: nil,
       proxy: nil,
+      user: nil,
+      password: nil,
       client_cert: nil,
       client_key: nil,
       client_key_pass: nil,
       client_cert_data: nil,
       client_key_data: nil
@@ -59,9 +63,11 @@
       @registry = registry || CachedConfluentSchemaRegistry.new(
         ConfluentSchemaRegistry.new(
           registry_url,
           logger: @logger,
           proxy: proxy,
+          user: user,
+          password: password,
           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