class LogStash::Inputs::Mqtt
Receive events from a MQTT topic
Public Instance Methods
register()
click to toggle source
# File lib/logstash/inputs/mqtt.rb, line 45 def register @host = Socket.gethostname @client = MQTT::Client.connect( :host => @mqttHost, :port => @port, :ssl => @ssl, :username => @username, :password => @password, :client_id => @client_id, :clean_session => @clean_session ) end
run(queue)
click to toggle source
# File lib/logstash/inputs/mqtt.rb, line 58 def run(queue) @client.subscribe(@topic => @qos) @client.get do |topic,message| @codec.decode(message) do |event| event.set("host", @host) event.set("topic", topic) decorate(event) queue << event end end end