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["host"] ||= @host
          event["topic"] = topic
          
          decorate(event)
          queue << event
      end
  end
end