Contents

# encoding: utf-8

$:.unshift('.')
$:.unshift(File.expand_path(File.dirname(__FILE__)) + '/../lib')

require 'mosquitto'

publisher = Mosquitto::Client.new
publisher.loop_start
publisher.on_log do |level,msg|
  p "PUB: #{msg}"
end
publisher.on_connect do |rc|
  p "Connect #{rc}"
  publisher.publish(nil, "topic", "test", Mosquitto::AT_MOST_ONCE, true)
end
publisher.connect("localhost", 1883, 10)
publisher.on_publish do |mid|
  p "Published #{mid}"
end
sleep 1.5
publisher.loop_stop(true)

subscriber = Mosquitto::Client.new
subscriber.loop_start
subscriber.on_log do |level,msg|
  p "SUB: #{msg}"
end
subscriber.on_connect do |rc|
  p "Connect #{rc}"
  subscriber.subscribe(nil, "topic", Mosquitto::AT_MOST_ONCE)
end
subscriber.on_subscribe do |mid,qos_count,granted_qos|
  p "Subscribed #{mid}"
end
subscriber.connect("localhost", 1883, 10)
subscriber.on_message do |msg|
  p "Message #{msg}"
end
sleep 1.5
subscriber.loop_stop(true)

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
mosquitto-0.3	examples/pub_sub.rb
mosquitto-0.2	examples/pub_sub.rb