Method: Fluent::Plugin::MqttProxy#start_proxy

Defined in:
lib/fluent/plugin/mqtt_proxy.rb

#start_proxy ⇒ Object 



55
56
57
58
59
60
 
# File 'lib/fluent/plugin/mqtt_proxy.rb', line 55

def start_proxy
  # Start a thread from main thread for handling a thread generated
  # by MQTT::Client#get (in_mqtt). Dummy thread is used for out_mqtt
  # to keep the same implementation style.
  @proxy_thread = thread_create("#{current_plugin_name}_proxy".to_sym, &method(:proxy))
end