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

@@ -42,12 +42,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)
       @connect.subscribe(@topic)
 
       @thread = Thread.new do
         @connect.get do |topic,message|