Contents

module NATS
  module RPC
    class Client
      def initialize(cluster_opts=nil)
        @nats = NATS::IO::Client.new
        @nats.connect cluster_opts || NATS::RPC.cluster_opts
      end

      def request(subscription, obj, opts)
        obj_json = if obj.is_a? String
          obj
        else
          obj.to_json
        end

        msg = @nats.request subscription, obj_json, opts
        data = JSON.parse(msg["data"])
        payload = JSON.parse(data["payload"])

        if data["status"] == "error"
          case data["code"]
          when 2.0
            rex = RemoteError.new payload["message"]
            rex.set_backtrace payload["backtrace"]
            rex.remote_exception = payload["exception"]
            raise rex
          else
            raise "Error code: #{data["code"]}"
          end
        end
        [data, payload]
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
nats-rpc-0.2.1	lib/nats/rpc/client.rb