如何识别publish
to atopic
是否成功。有什么方法可以在发布到某个主题时得到确认。
如果publish
客户端(发布者/订阅者)之间的连接丢失如何处理。
我不希望订阅者在收到 pay_load 后向发布端的特定主题发送 ack。
这是我的红宝石代码:
假设,我已经创建了客户端(@client)
并在两侧进行了配置。
发布
def publish_it
@client.publish('test/hai', 'message')
# Ack the publish
end
订阅
@client.subscribe('test/#')
@client.get do |topic,message|
puts "#{topic}: #{message}"
end