test/plugin/test_in_mqtt.rb in fluent-plugin-mqtt-io-0.3.8 vs test/plugin/test_in_mqtt.rb in fluent-plugin-mqtt-io-0.3.9

@@ -9,24 +9,41 @@
 
 
   CONFIG = %[
   ]
 
-  def create_driver(conf = CONFIG, opts = {}) 
+  def create_driver(conf = CONFIG, opts = {})
     Fluent::Test::Driver::Input.new(Fluent::Plugin::MqttInput, opts: opts).configure(conf)
   end
 
   sub_test_case "configure" do
     test "host and port" do
       d = create_driver %[
           host 127.0.0.1
           port 1300
+          client_id aa-bb-cc-dd
           <parse>
             @type json
             time_format %FT%T%:z
           </parse>
+          <security>
+            use_tls true
+            <tls>
+              ca_file /cert/cacert.pem
+              key_file /cert/private.key
+              cert_file /cert/cert.pem
+            </tls>
+          </security>
+
       ]
       assert_equal '127.0.0.1', d.instance.host
       assert_equal 1300, d.instance.port
+      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
+      assert_equal '/cert/cert.pem', d.instance.security.tls.cert_file
+
     end
   end
 end