test/plugin/test_out_mqtt.rb in fluent-plugin-mqtt-io-0.4.0 vs test/plugin/test_out_mqtt.rb in fluent-plugin-mqtt-io-0.4.1
- old
+ new
@@ -19,13 +19,15 @@
test 'configure' do
d = create_driver %[
host 127.0.0.1
port 1300
client_id aa-bb-cc-dd
- <format>
- @type json
- </format>
+ retain true
+ qos 2
+ <buffer>
+ async true
+ </buffer>
<monitor>
send_time true
</monitor>
<security>
use_tls true
@@ -36,11 +38,18 @@
</tls>
</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 'aa-bb-cc-dd', d.instance.client_id
+ assert_equal true, d.instance.retain
+ assert_equal 2, d.instance.qos
+
+ assert_equal true, d.instance.buffer_config.async
+
+ assert_equal true, d.instance.monitor.send_time
+
+ # cannot test formatter configuration (default: single_value)
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
assert_equal '/cert/cert.pem', d.instance.security.tls.cert_file