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