mqtt_reconstruct_object.rb

# Convert an object to JSON, push it over MQTT,
# and reconstruct the object.

require 'mqtt'
require 'json'

# ip = '192.168.0.61'
ip = '10.0.1.27'

send = OpenStruct.new val_1:123, val_2:456
@obj = nil

# Topic listener.
thread = Thread.new do
  MQTT::Client.connect ip do |c|
    # This works, but "c.get do" loops.
    # c.get '/test' do |topic, msg|
    #   @obj = OpenStruct.new JSON.parse(msg)
    #   p @obj
    # end
    
    @obj = OpenStruct.new JSON.parse c.get('/test').last
    p @obj
  end
end

sleep 0.1

# Topic publisher.
MQTT::Client.connect ip do |c|
  c.publish '/test', JSON.generate(send.to_h)
end

thread.join