test_in_mqtt.rb in fluent-plugin-mqtt-io-0.4.1

- old
+ new

@@ -19,14 +19,13 @@
     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>
+          <monitor>
+            recv_time true
+          </monitor>
           <security>
             use_tls true
             <tls>
               ca_file /cert/cacert.pem
               key_file /cert/private.key
@@ -36,9 +35,13 @@
 
       ]
       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 'none', d.instance.parser_configs.first[:@type]
+
+      assert_equal true, d.instance.monitor.recv_time
 
       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