lib/fluent/plugin/mqtt_proxy.rb in fluent-plugin-mqtt-io-0.4.3 vs lib/fluent/plugin/mqtt_proxy.rb in fluent-plugin-mqtt-io-0.4.4

@@ -53,10 +53,10 @@
       log.debug "start to connect mqtt broker #{@host}:#{@port}"
       opts = {
         host: @host,
         port: @port,
         client_id: @client_id,
-        clean_session: @clean_session
+        clean_session: @clean_session,
         keep_alive: @keep_alive
       }
       opts[:username] = @security.username if @security.to_h.has_key?(:username)
       opts[:password] = @security.password if @security.to_h.has_key?(:password)
       if @security.to_h.has_key?(:use_tls) && @security.use_tls