mqttコネクションはるやつ

mqtt.rb

require 'mqtt'
require 'uri'

uri = URI.parse(ENV['ACCESS_POINT'])

client = MQTT::Client.connect(
  remote_host: uri.host,
  remote_port: uri.port,
  username: ENV['USER'],
  password: ENV['PASS'],
)

#topic = ENV['TOPIC'].gsub('#', 'huge')
#client.publish(topic, 'message')
client.get(ENV['TOPIC']) do |topic,message|
  p "topic:[#{topic}] message:[#{message}]"
end