lib/fluent/plugin/mqtt_output_mixin.rb in fluent-plugin-mqtt-io-0.0.3 vs lib/fluent/plugin/mqtt_output_mixin.rb in fluent-plugin-mqtt-io-0.0.4

@@ -48,12 +48,12 @@
         port: @port,
         username: @username,
         password: @password
       }
       opts[:ssl] = @ssl if @ssl
-      opts[:ca_file] = @ca if @ca
-      opts[:cert_file] = @crt if @crt
-      opts[:key_file] = @key if @key
+      opts[:ca_file] = @ca_file if @ca_file
+      opts[:cert_file] = @cert_file if @cert_file
+      opts[:key_file] = @key_file if @key_file
       @connect = MQTT::Client.connect(opts)
     end
 
     # This method is called when shutting down.
     # Shutdown the thread and close sockets or files here.