class CamTool::MQTTBreaker
Public Class Methods
new()
click to toggle source
# File lib/camtool/breaker_mqtt.rb, line 7 def initialize conn_opts = { remote_host: 'm12.cloudmqtt.com', remote_port: 17065, username: 'camflow', password: 'test', } @c = MQTT::Client.connect conn_opts end
Public Instance Methods
new_entry(entry)
click to toggle source
# File lib/camtool/breaker_mqtt.rb, line 17 def new_entry entry comp = Zlib::Deflate.deflate entry ready = Base64.encode64 comp @c.publish 'camflow/test', ready sleep 5 end