lib/fluent/plugin/out_mqtt.rb in fluent-plugin-mqtt-io-0.0.6 vs lib/fluent/plugin/out_mqtt.rb in fluent-plugin-mqtt-io-0.1.0

@@ -8,10 +8,10 @@
     Fluent::Plugin.register_output('mqtt', self)
 
     def emit(tag, es, chain)
       es.each {|time,record|
         $log.debug "#{tag}, #{format_time(time)}, #{record}"
-        @connect.publish(rewrite_tag(tag), record.merge(timestamp_hash(time)).to_json)
+        @client.publish(rewrite_tag(tag), record.merge(timestamp_hash(time)).to_json)
       }
       $log.flush
 
       chain.next
     end