Class: TiltHydrometer::MQTT

Inherits:
Object
  • Object
show all
Defined in:
lib/tilt_hydrometer/mqtt.rb

Instance Method Summary collapse

Constructor Details

#initialize(mqtt_uri, prefix) ⇒ MQTT

Returns a new instance of MQTT.



5
6
7
8
# File 'lib/tilt_hydrometer/mqtt.rb', line 5

def initialize(mqtt_uri, prefix)
  @mqtt_uri = mqtt_uri
  @prefix = prefix
end

Instance Method Details

#publish(beacon) ⇒ Object



10
11
12
13
14
# File 'lib/tilt_hydrometer/mqtt.rb', line 10

def publish(beacon)
  ::MQTT::Client.connect(@mqtt_uri) do |c|
    c.publish(topic(beacon), beacon_json(beacon), true)
  end
end