require_relative '../helper'
require 'fluent/test/driver/input'
require 'fluent/plugin/in_mqtt'
class MqttInputTest < Test::Unit::TestCase
def setup
Fluent::Test.setup
end
CONFIG = %[
]
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
recv_time true
use_tls true
ca_file /cert/cacert.pem
key_file /cert/private.key
cert_file /cert/cert.pem
]
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
end
end
end