Contents

require_relative '../helper'
require 'fluent/test/driver/output'
require 'fluent/plugin/out_mqtt'

class MqttOutputTest < Test::Unit::TestCase
  def setup
    Fluent::Test.setup
  end


  CONFIG = %[
  ]

  def create_driver(conf = CONFIG, opts = {}) 
    Fluent::Test::Driver::Output.new(Fluent::Plugin::MqttOutput, opts: opts).configure(conf)
  end

  sub_test_case 'non-buffered' do
    test 'configure' do
      d = create_driver %[
        host 127.0.0.1
        port 1300
        <format>
          @type json
        </format>
      ]
      assert_equal '127.0.0.1', d.instance.host
      assert_equal 1300, d.instance.port
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
fluent-plugin-mqtt-io-0.3.8	test/plugin/test_out_mqtt.rb
fluent-plugin-mqtt-io-0.3.7	test/plugin/test_out_mqtt.rb
fluent-plugin-mqtt-io-0.3.6	test/plugin/test_out_mqtt.rb
fluent-plugin-mqtt-io-0.3.5	test/plugin/test_out_mqtt.rb
fluent-plugin-mqtt-io-0.3.4	test/plugin/test_out_mqtt.rb
fluent-plugin-mqtt-io-0.3.3	test/plugin/test_out_mqtt.rb
fluent-plugin-mqtt-io-0.3.1	test/plugin/test_out_mqtt.rb
fluent-plugin-mqtt-io-0.3.0	test/plugin/test_out_mqtt.rb