test_out_mqtt.rb in fluent-plugin-mqtt-io-0.3.10

- old
+ new

@@ -19,10 +19,12 @@
     test 'configure' do
       d = create_driver %[
         host 127.0.0.1
         port 1300
         client_id aa-bb-cc-dd
+        retain true
+        qos 2
         <format>
           @type json
         </format>
         <monitor>
           send_time true
@@ -37,9 +39,11 @@
         </security>
       ]
       assert_equal '127.0.0.1', d.instance.host
       assert_equal 1300, d.instance.port
       assert_equal true, d.instance.monitor.send_time
+      assert_equal true, d.instance.retain
+      assert_equal 2, d.instance.qos
       assert_equal 'aa-bb-cc-dd', d.instance.client_id
 
       assert_equal true, d.instance.security.use_tls
       assert_equal '/cert/cacert.pem', d.instance.security.tls.ca_file
       assert_equal '/cert/private.key', d.instance.security.tls.key_file