MQTTRpc

rabbitmq RPC on mqtt，轻量级通讯协议的同步请求

Installation

Add this line to your application's Gemfile:

gem 'mqtt_rpc'

And then execute:

$ bundle

Or install it yourself as:

$ gem install mqtt_rpc

Usage

  require 'mqtt_rpc'

  client = MQTTRpc::Client.new(options)

  3 seconds will timeout
  client = MQTTRpc::Client.new(options, 3)

  response_body = client.publish('request_topic', 'message', 'response_topic')