Sha256: 21a8761f1753aa2178aba14dd2ff024061c7815fee245c28bfd5209b5c1b56d4
Contents?: true
Size: 1.34 KB
Versions: 5
Compression:
Stored size: 1.34 KB
Contents
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
<monitor>
recv_time true
</monitor>
<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 '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
Version data entries
5 entries across 5 versions & 1 rubygems