lib/fluent/plugin/out_mqtt.rb in fluent-plugin-mqtt-io-0.3.10 vs lib/fluent/plugin/out_mqtt.rb in fluent-plugin-mqtt-io-0.4.0

@@ -16,15 +16,10 @@
     desc 'Topic rewrite matching pattern.'
     config_param :topic_rewrite_pattern, :string, default: nil
     desc 'Topic rewrite replacement string.'
     config_param :topic_rewrite_replacement, :string, default: nil
 
-    desc 'Retain option which publishing'
-    config_param :retain, :bool, default: false
-    desc 'QoS option which publishing'
-    config_param :qos, :integer, default: 1
-
     config_section :format do
       desc 'The format to publish'
       config_param :@type, :string, default: 'single_value'
       desc 'Add newline'
       config_param :add_newline, :bool, default: false
@@ -142,15 +137,10 @@
     def write(chunk)
       return if chunk.empty?
       chunk.each do |tag, time, record|
         rescue_disconnection do
           log.debug "MqttOutput#write: #{rewrite_tag(rewrite_tag(tag))}, #{time}, #{add_send_time(record)}"
-          @client.publish(
-            rewrite_tag(tag),
-            @formatter.format(tag, time, add_send_time(record)),
-            @retain,
-            @qos
-          )
+          @client.publish(rewrite_tag(tag), @formatter.format(tag, time, add_send_time(record)))
         end
       end
     end
   end
 end