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

@@ -16,10 +16,15 @@
     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
@@ -137,10 +142,15 @@
     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)))
+          @client.publish(
+            rewrite_tag(tag),
+            @formatter.format(tag, time, add_send_time(record)),
+            @retain,
+            @qos
+          )
         end
       end
     end
   end
 end