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