lib/fluent/plugin/in_mqtt.rb in fluent-plugin-mqtt-0.0.5 vs lib/fluent/plugin/in_mqtt.rb in fluent-plugin-mqtt-0.0.6
- old
+ new
@@ -46,10 +46,10 @@
port: @port}
opts[:username] = @username if @username
opts[:password] = @password if @password
opts[:ssl] = @ssl if @ssl
opts[:ca_file] = @ca if @ca
- opts[:cert_file] = @crt if @crt
+ opts[:cert_file] = @cert if @cert
opts[:key_file] = @key if @key
@connect = MQTT::Client.connect(opts)
@connect.subscribe(@topic)
@thread = Thread.new do