class MQTTReader

Attributes

temperature[R]

Public Class Methods

new() click to toggle source
# File lib/read_mqtt.rb, line 9
def initialize
        $temperature
end

Public Instance Methods

read(ttn_host, port, username, password, sensor_id) click to toggle source
# File lib/read_mqtt.rb, line 13
  def read (ttn_host, port, username, password, sensor_id)
MQTT::Client.connect(
      :host => ttn_host,
      :port => port,
      :username => username,
      :password => password
    ) do |c|
  c.get(sensor_id) do |topic,message|
    obj = JSON.parse("#{message}")
    $temperature = obj['fields']['temperature']
                          c.disconnect()
  end
end
  end